org.apache.paimon.flink.sink

Class LogFlinkSinkBuilder

java.lang.Object

org.apache.paimon.flink.sink.FlinkSinkBuilder

org.apache.paimon.flink.sink.LogFlinkSinkBuilder

public class LogFlinkSinkBuilder
extends FlinkSinkBuilder

A special version FlinkSinkBuilder with log sink.

Field Summary

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

compactSink, logSinkFunction, overwritePartition, parallelism, table

Constructor Summary

Constructors

Constructor and Description
LogFlinkSinkBuilder(Table table)

Method Summary

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

LogFlinkSinkBuilder

public LogFlinkSinkBuilder(Table table)