org.apache.paimon.flink.sink

Class CompactorSinkBuilder

java.lang.Object

org.apache.paimon.flink.sink.CompactorSinkBuilder

public class CompactorSinkBuilder
extends Object

Builder for CompactorSink.

Constructor Summary

Constructors

Constructor and Description
CompactorSinkBuilder(FileStoreTable table)

Method Summary

Modifier and Type	Method and Description
org.apache.flink.streaming.api.datastream.DataStreamSink<?>	build()
CompactorSinkBuilder	withFullCompaction(boolean fullCompaction)
CompactorSinkBuilder	withInput(org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData> input)

Methods inherited from class java.lang.Object

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

Constructor Detail

CompactorSinkBuilder

public CompactorSinkBuilder(FileStoreTable table)

Method Detail

withInput

public CompactorSinkBuilder withInput(org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData> input)

withFullCompaction

public CompactorSinkBuilder withFullCompaction(boolean fullCompaction)

build

public org.apache.flink.streaming.api.datastream.DataStreamSink<?> build()