Uses of Class
org.apache.paimon.flink.sink.FlinkSinkBuilder

Packages that use FlinkSinkBuilder

Package	Description
org.apache.paimon.flink.sink

Uses of FlinkSinkBuilder in org.apache.paimon.flink.sink

Subclasses of FlinkSinkBuilder in org.apache.paimon.flink.sink

Modifier and Type	Class and Description
class	LogFlinkSinkBuilder A special version FlinkSinkBuilder with log sink.
class	SortCompactSinkBuilder A special version FlinkSinkBuilder for sort compact.

Methods in org.apache.paimon.flink.sink that return FlinkSinkBuilder

Modifier and Type	Method and Description
FlinkSinkBuilder	FlinkSinkBuilder.clusteringIfPossible(String clusteringColumns, String clusteringStrategy, boolean sortInCluster, int sampleFactor) Clustering the input data if possible.
FlinkSinkBuilder	SortCompactSinkBuilder.forCompact(boolean compactSink)
FlinkSinkBuilder	FlinkSinkBuilder.forRow(org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.types.Row> input, org.apache.flink.table.types.DataType rowDataType) From DataStream with Row, need to provide a DataType for builder to convert those Rows to a RowData DataStream.
FlinkSinkBuilder	FlinkSinkBuilder.forRowData(org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData> input) From DataStream with RowData.
FlinkSinkBuilder	FlinkSinkBuilder.overwrite() INSERT OVERWRITE.
FlinkSinkBuilder	FlinkSinkBuilder.overwrite(Map<String,String> overwritePartition) INSERT OVERWRITE PARTITION (...).
FlinkSinkBuilder	FlinkSinkBuilder.parallelism(int parallelism) Set sink parallelism.