Uses of Class
org.apache.paimon.append.MultiTableAppendCompactTask

Packages that use MultiTableAppendCompactTask

Package	Description
org.apache.paimon.flink.sink
org.apache.paimon.flink.source
org.apache.paimon.flink.source.operator
org.apache.paimon.table.sink

Uses of MultiTableAppendCompactTask in org.apache.paimon.flink.sink

Methods in org.apache.paimon.flink.sink that return types with arguments of type MultiTableAppendCompactTask

Modifier and Type	Method and Description
org.apache.flink.api.common.typeutils.TypeSerializer<MultiTableAppendCompactTask>	MultiTableCompactionTaskTypeInfo.createSerializer(org.apache.flink.api.common.ExecutionConfig executionConfig) Do not annotate with @override here to maintain compatibility with Flink 2.0+.
org.apache.flink.api.common.typeutils.TypeSerializer<MultiTableAppendCompactTask>	MultiTableCompactionTaskTypeInfo.createSerializer(SerializerConfig serializerConfig) Do not annotate with @override here to maintain compatibility with Flink 1.18-.
Class<MultiTableAppendCompactTask>	MultiTableCompactionTaskTypeInfo.getTypeClass()

Method parameters in org.apache.paimon.flink.sink with type arguments of type MultiTableAppendCompactTask

Modifier and Type	Method and Description
org.apache.flink.streaming.api.datastream.DataStream<MultiTableCommittable>	CombinedTableCompactorSink.doWrite(org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData> awareBucketTableSource, org.apache.flink.streaming.api.datastream.DataStream<MultiTableAppendCompactTask> unawareBucketTableSource, String commitUser)
void	AppendOnlyMultiTableCompactionWorkerOperator.processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<MultiTableAppendCompactTask> element)
org.apache.flink.streaming.api.datastream.DataStreamSink<?>	CombinedTableCompactorSink.sinkFrom(org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData> awareBucketTableSource, org.apache.flink.streaming.api.datastream.DataStream<MultiTableAppendCompactTask> unawareBucketTableSource)
org.apache.flink.streaming.api.datastream.DataStreamSink<?>	CombinedTableCompactorSink.sinkFrom(org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData> awareBucketTableSource, org.apache.flink.streaming.api.datastream.DataStream<MultiTableAppendCompactTask> unawareBucketTableSource, String initialCommitUser)

Uses of MultiTableAppendCompactTask in org.apache.paimon.flink.source

Methods in org.apache.paimon.flink.source that return types with arguments of type MultiTableAppendCompactTask

Modifier and Type	Method and Description
org.apache.flink.streaming.api.datastream.DataStream<MultiTableAppendCompactTask>	CombinedTableCompactorSourceBuilder.buildForUnawareBucketsTableSource()

Uses of MultiTableAppendCompactTask in org.apache.paimon.flink.source.operator

Methods in org.apache.paimon.flink.source.operator that return types with arguments of type MultiTableAppendCompactTask

Modifier and Type	Method and Description
static org.apache.flink.streaming.api.datastream.DataStream<MultiTableAppendCompactTask>	CombinedAppendCompactSource.buildSource(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env, String name, CatalogLoader catalogLoader, Pattern includingPattern, Pattern excludingPattern, Pattern databasePattern, Map<String,String> tableOptions, java.time.Duration partitionIdleTime)
static org.apache.flink.streaming.api.datastream.DataStream<MultiTableAppendCompactTask>	CombinedAppendCompactStreamSource.buildSource(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env, String name, CatalogLoader catalogLoader, Pattern includingPattern, Pattern excludingPattern, Pattern databasePattern, Map<String,String> tableOptions, long monitorInterval)
org.apache.flink.api.connector.source.SourceReader<MultiTableAppendCompactTask,SimpleSourceSplit>	CombinedAppendCompactStreamSource.createReader(org.apache.flink.api.connector.source.SourceReaderContext sourceReaderContext)
org.apache.flink.api.connector.source.SourceReader<MultiTableAppendCompactTask,SimpleSourceSplit>	CombinedAppendCompactSource.createReader(org.apache.flink.api.connector.source.SourceReaderContext sourceReaderContext)

Method parameters in org.apache.paimon.flink.source.operator with type arguments of type MultiTableAppendCompactTask

Modifier and Type	Method and Description
void	MultiTableAppendCompactReadOperator.processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<MultiTableAppendCompactTask> record)

Uses of MultiTableAppendCompactTask in org.apache.paimon.table.sink

Methods in org.apache.paimon.table.sink that return MultiTableAppendCompactTask

Modifier and Type	Method and Description
MultiTableAppendCompactTask	MultiTableCompactionTaskSerializer.deserialize(int version, byte[] serialized)

Methods in org.apache.paimon.table.sink that return types with arguments of type MultiTableAppendCompactTask

Modifier and Type	Method and Description
List<MultiTableAppendCompactTask>	MultiTableCompactionTaskSerializer.deserializeList(int version, DataInputView view)

Methods in org.apache.paimon.table.sink with parameters of type MultiTableAppendCompactTask

Modifier and Type	Method and Description
byte[]	MultiTableCompactionTaskSerializer.serialize(MultiTableAppendCompactTask task)

Method parameters in org.apache.paimon.table.sink with type arguments of type MultiTableAppendCompactTask

Modifier and Type	Method and Description
void	MultiTableCompactionTaskSerializer.serializeList(List<MultiTableAppendCompactTask> list, DataOutputView view)