org.apache.paimon.flink.sink

Class AppendCompactWorkerOperator.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.AppendCompactWorkerOperator.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:

AppendBypassCompactWorkerOperator.Factory, AppendOnlySingleTableCompactionWorkerOperator.Factory

Enclosing class:

AppendCompactWorkerOperator<IN>

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

StreamOperatorFactory of AppendCompactWorkerOperator.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected String	commitUser
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, String commitUser)

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

commitUser

protected final String commitUser

Constructor Detail

Factory

protected Factory(FileStoreTable table,
                  String commitUser)