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

Packages that use MultiTableUnawareAppendCompactionTask

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 MultiTableUnawareAppendCompactionTask in org.apache.paimon.flink.sink

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

Modifier and Type	Method and Description
org.apache.flink.api.common.typeutils.TypeSerializer<MultiTableUnawareAppendCompactionTask>	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<MultiTableUnawareAppendCompactionTask>	MultiTableCompactionTaskTypeInfo.createSerializer(SerializerConfig serializerConfig) Do not annotate with @override here to maintain compatibility with Flink 1.18-.
Class<MultiTableUnawareAppendCompactionTask>	MultiTableCompactionTaskTypeInfo.getTypeClass()

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

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<MultiTableUnawareAppendCompactionTask> unawareBucketTableSource, String commitUser)
void	AppendOnlyMultiTableCompactionWorkerOperator.processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<MultiTableUnawareAppendCompactionTask> 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<MultiTableUnawareAppendCompactionTask> 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<MultiTableUnawareAppendCompactionTask> unawareBucketTableSource, String initialCommitUser)

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

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

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

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

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

Modifier and Type	Method and Description
static org.apache.flink.streaming.api.datastream.DataStream<MultiTableUnawareAppendCompactionTask>	CombinedUnawareBatchSourceFunction.buildSource(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env, String name, Catalog.Loader catalogLoader, Pattern includingPattern, Pattern excludingPattern, Pattern databasePattern, java.time.Duration partitionIdleTime)
static org.apache.flink.streaming.api.datastream.DataStream<MultiTableUnawareAppendCompactionTask>	CombinedUnawareStreamingSourceFunction.buildSource(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env, String name, Catalog.Loader catalogLoader, Pattern includingPattern, Pattern excludingPattern, Pattern databasePattern, long monitorInterval)

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

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

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

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

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

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

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

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

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

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

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