Package | Description |
---|---|
org.apache.paimon.flink.sink |
Modifier and Type | Method and Description |
---|---|
protected HashBucketAssignerOperator<T> |
DynamicBucketSink.createHashBucketAssignerOperator(String commitUser,
Table table,
Integer numAssigners,
SerializableFunction<TableSchema,PartitionKeyExtractor<T>> extractorFunction,
boolean overwrite) |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.