[feature](sink) support paritition tablet sink shuffle

zhangstar333 · Feb 4, 2024 · 9ca608e · 9ca608e
1 parent 1e3af61
commit 9ca608e
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 1 deletion.
diff --git a/gensrc/thrift/DataSinks.thrift b/gensrc/thrift/DataSinks.thrift
@@ -169,6 +169,10 @@ struct TDataStreamSink {
 
     // per-destination runtime filters
     7: optional list<PlanNodes.TRuntimeFilterDesc> runtime_filters
+
+  // used for partition_type = PARTITION_TABLET_SINK_SHUFFLE
+  8: optional Descriptors.TOlapTableSchemaParam schema
+  9: optional Descriptors.TOlapTablePartitionParam partition
 }
 
 struct TMultiCastDataStreamSink {

diff --git a/gensrc/thrift/Partitions.thrift b/gensrc/thrift/Partitions.thrift
@@ -40,7 +40,10 @@ enum TPartitionType {
 
   // unordered partition on a set of exprs
   // (only use in bucket shuffle join)
-  BUCKET_SHFFULE_HASH_PARTITIONED
+  BUCKET_SHFFULE_HASH_PARTITIONED,
+
+  // used for shuffle data by parititon and tablet
+  PARTITION_TABLET_SINK_SHUFFLE
 }
 
 enum TDistributionType {