org.apache.paimon.flink.sink

Class TableWriteOperator.Factory<IN>

java.lang.Object

org.apache.flink.streaming.api.operators.AbstractStreamOperatorFactory<OUT>

org.apache.paimon.flink.sink.PrepareCommitOperator.Factory<IN,Committable>

org.apache.paimon.flink.sink.TableWriteOperator.Factory<IN>

All Implemented Interfaces:

Serializable, org.apache.flink.streaming.api.operators.OneInputStreamOperatorFactory<IN,Committable>, org.apache.flink.streaming.api.operators.StreamOperatorFactory<Committable>, org.apache.flink.streaming.runtime.tasks.ProcessingTimeServiceAware

Direct Known Subclasses:

CdcDynamicBucketWriteOperator.Factory, CdcRecordStoreWriteOperator.Factory, DynamicBucketRowWriteOperator.Factory, RowDataStoreWriteOperator.Factory

Enclosing class:

TableWriteOperator<IN>

protected abstract static class TableWriteOperator.Factory<IN>
extends PrepareCommitOperator.Factory<IN,Committable>

StreamOperatorFactory of TableWriteOperator.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected String	initialCommitUser
protected StoreSinkWrite.Provider	storeSinkWriteProvider
protected FileStoreTable	table

Fields inherited from class org.apache.paimon.flink.sink.PrepareCommitOperator.Factory

options

Fields inherited from class org.apache.flink.streaming.api.operators.AbstractStreamOperatorFactory

chainingStrategy, processingTimeService

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	Factory(FileStoreTable table, StoreSinkWrite.Provider storeSinkWriteProvider, String initialCommitUser)

Method Summary

Methods inherited from class org.apache.flink.streaming.api.operators.AbstractStreamOperatorFactory

getChainingStrategy, getMailboxExecutor, setChainingStrategy, setMailboxExecutor, setProcessingTimeService

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.streaming.api.operators.StreamOperatorFactory

createStreamOperator, getChainingStrategy, getOperatorAttributes, getStreamOperatorClass, isInputTypeConfigurable, isLegacySource, isOutputTypeConfigurable, isStreamSource, setChainingStrategy, setInputType, setOutputType

Field Detail

table

protected final FileStoreTable table

storeSinkWriteProvider

protected final StoreSinkWrite.Provider storeSinkWriteProvider

initialCommitUser

protected final String initialCommitUser

Constructor Detail

Factory

protected Factory(FileStoreTable table,
                  StoreSinkWrite.Provider storeSinkWriteProvider,
                  String initialCommitUser)