org.apache.paimon.flink.sink

Class SortCompactSinkBuilder

java.lang.Object

org.apache.paimon.flink.sink.FlinkSinkBuilder

org.apache.paimon.flink.sink.SortCompactSinkBuilder

public class SortCompactSinkBuilder
extends FlinkSinkBuilder

A special version FlinkSinkBuilder for sort compact.

Field Summary

Fields inherited from class org.apache.paimon.flink.sink.FlinkSinkBuilder

compactSink, logSinkFunction, overwritePartition, parallelism, table

Constructor Summary

Constructors

Constructor and Description
SortCompactSinkBuilder(Table table)

Method Summary

Modifier and Type	Method and Description
FlinkSinkBuilder	forCompact(boolean compactSink)

Methods inherited from class org.apache.paimon.flink.sink.FlinkSinkBuilder

build, buildDynamicBucketSink, buildForFixedBucket, clusteringIfPossible, forRow, forRowData, mapToInternalRow, overwrite, overwrite, parallelism

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SortCompactSinkBuilder

public SortCompactSinkBuilder(Table table)

Method Detail

forCompact

public FlinkSinkBuilder forCompact(boolean compactSink)