public class FlinkSinkBuilder extends Object
FileStoreSink
.Constructor and Description |
---|
FlinkSinkBuilder(FileStoreTable table) |
Modifier and Type | Method and Description |
---|---|
org.apache.flink.streaming.api.datastream.DataStreamSink<?> |
build() |
FlinkSinkBuilder |
withInput(org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData> input) |
FlinkSinkBuilder |
withLockFactory(Lock.Factory lockFactory) |
FlinkSinkBuilder |
withLogSinkFunction(LogSinkFunction logSinkFunction) |
FlinkSinkBuilder |
withOverwritePartition(Map<String,String> overwritePartition) |
FlinkSinkBuilder |
withParallelism(Integer parallelism) |
public FlinkSinkBuilder(FileStoreTable table)
public FlinkSinkBuilder withInput(org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData> input)
public FlinkSinkBuilder withLockFactory(Lock.Factory lockFactory)
public FlinkSinkBuilder withOverwritePartition(Map<String,String> overwritePartition)
public FlinkSinkBuilder withLogSinkFunction(@Nullable LogSinkFunction logSinkFunction)
public FlinkSinkBuilder withParallelism(@Nullable Integer parallelism)
public org.apache.flink.streaming.api.datastream.DataStreamSink<?> build()
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.