chore(cubestore): Upgrade DF: Return finer EmissionType values

Author: srh

rust/cubestore/cubestore/src/queryplanner/mod.rs

@@ -756,7 +756,7 @@ impl TableProvider for InfoSchemaTableProvider {
             properties: PlanProperties::new(
                 EquivalenceProperties::new(schema),
                 Partitioning::UnknownPartitioning(1),
-                EmissionType::Both, // TODO upgrade DF:  Both is safe choice
+                EmissionType::Final,
                 Boundedness::Bounded,
             ),
         };

rust/cubestore/cubestore/src/queryplanner/query_executor.rs

@@ -894,7 +894,7 @@ impl CubeTable {
                     )?)],
                 ),
                 Partitioning::UnknownPartitioning(partition_num),
-                EmissionType::Both, // TODO upgrade DF
+                EmissionType::Incremental,
                 Boundedness::Bounded,
             ),
         });
@@ -1084,7 +1084,7 @@ impl ExecutionPlan for CubeTableExec {
                     )?)],
                 ),
                 Partitioning::UnknownPartitioning(partition_count),
-                EmissionType::Both, // TODO upgrade DF
+                EmissionType::Incremental,
                 Boundedness::Bounded,
             ),
         }))
@@ -1348,7 +1348,7 @@ impl ClusterSendExec {
         PlanProperties::new(
             eq_properties,
             Partitioning::UnknownPartitioning(partitions_num),
-            EmissionType::Both, // TODO upgrade DF: Actually Final, unless we implement streaming, but check if that value has implications.
+            EmissionType::Both, // Or Final, but we should implement streaming.
             input_properties.boundedness.clone(),
         )
     }

rust/cubestore/cubestore/src/queryplanner/rolling.rs

@@ -590,7 +590,7 @@ impl ExtensionPlanner for RollingWindowPlanner {
                 // EquivalenceProperties::new_with_orderings(schema.clone().into(), &[sort_key]),
                 EquivalenceProperties::new(schema.clone().into()),
                 Partitioning::UnknownPartitioning(1),
-                EmissionType::Both, // TODO upgrade DF
+                EmissionType::Final,
                 Boundedness::Bounded,
             ),
             sorted_input: sort,