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

Packages that use UnawareAppendCompactionTask

Package	Description
org.apache.paimon.append
org.apache.paimon.flink.compact
org.apache.paimon.flink.sink
org.apache.paimon.flink.source
org.apache.paimon.table.sink

Uses of UnawareAppendCompactionTask in org.apache.paimon.append

Subclasses of UnawareAppendCompactionTask in org.apache.paimon.append

Modifier and Type	Class and Description
class	MultiTableUnawareAppendCompactionTask Compaction task for multi table .

Methods in org.apache.paimon.append that return types with arguments of type UnawareAppendCompactionTask

Modifier and Type	Method and Description
List<UnawareAppendCompactionTask>	UnawareAppendTableCompactionCoordinator.run()

Uses of UnawareAppendCompactionTask in org.apache.paimon.flink.compact

Methods in org.apache.paimon.flink.compact with parameters of type UnawareAppendCompactionTask

Modifier and Type	Method and Description
void	UnawareBucketCompactor.processElement(UnawareAppendCompactionTask task)

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

Methods in org.apache.paimon.flink.sink that return UnawareAppendCompactionTask

Modifier and Type	Method and Description
UnawareAppendCompactionTask	CompactionTaskSimpleSerializer.deserialize(int compactionTaskVersion, byte[] bytes)

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

Modifier and Type	Method and Description
org.apache.flink.api.common.typeutils.TypeSerializer<UnawareAppendCompactionTask>	CompactionTaskTypeInfo.createSerializer(org.apache.flink.api.common.ExecutionConfig config) Do not annotate with @override here to maintain compatibility with Flink 2.0+.
org.apache.flink.api.common.typeutils.TypeSerializer<UnawareAppendCompactionTask>	CompactionTaskTypeInfo.createSerializer(SerializerConfig config) Do not annotate with @override here to maintain compatibility with Flink 1.18-.
protected org.apache.flink.streaming.api.operators.OneInputStreamOperatorFactory<UnawareAppendCompactionTask,Committable>	UnawareBucketCompactionSink.createWriteOperatorFactory(StoreSinkWrite.Provider writeProvider, String commitUser)
Class<UnawareAppendCompactionTask>	CompactionTaskTypeInfo.getTypeClass()

Methods in org.apache.paimon.flink.sink with parameters of type UnawareAppendCompactionTask

Modifier and Type	Method and Description
byte[]	CompactionTaskSimpleSerializer.serialize(UnawareAppendCompactionTask compactionTask)

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

Modifier and Type	Method and Description
void	AppendBypassCompactWorkerOperator.processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<org.apache.flink.types.Either<Committable,UnawareAppendCompactionTask>> element)
void	AppendOnlySingleTableCompactionWorkerOperator.processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<UnawareAppendCompactionTask> element)
static org.apache.flink.streaming.api.datastream.DataStreamSink<?>	UnawareBucketCompactionSink.sink(FileStoreTable table, org.apache.flink.streaming.api.datastream.DataStream<UnawareAppendCompactionTask> input)

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

Methods in org.apache.paimon.flink.source with type parameters of type UnawareAppendCompactionTask

Modifier and Type	Method and Description
<T extends org.apache.flink.streaming.api.operators.StreamOperator<org.apache.flink.types.Either<CommitT,UnawareAppendCompactionTask>>> T	AppendBypassCoordinateOperatorFactory.createStreamOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<org.apache.flink.types.Either<CommitT,UnawareAppendCompactionTask>> parameters)

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

Modifier and Type	Method and Description
static org.apache.flink.streaming.api.datastream.DataStreamSource<UnawareAppendCompactionTask>	BucketUnawareCompactSource.buildSource(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env, BucketUnawareCompactSource source, String tableIdentifier)
org.apache.flink.api.connector.source.SourceReader<UnawareAppendCompactionTask,SimpleSourceSplit>	BucketUnawareCompactSource.createReader(org.apache.flink.api.connector.source.SourceReaderContext readerContext)

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

Modifier and Type	Method and Description
<T extends org.apache.flink.streaming.api.operators.StreamOperator<org.apache.flink.types.Either<CommitT,UnawareAppendCompactionTask>>> T	AppendBypassCoordinateOperatorFactory.createStreamOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<org.apache.flink.types.Either<CommitT,UnawareAppendCompactionTask>> parameters)
org.apache.flink.core.io.InputStatus	BucketUnawareCompactSource.BucketUnawareCompactSourceReader.pollNext(org.apache.flink.api.connector.source.ReaderOutput<UnawareAppendCompactionTask> readerOutput)

Constructor parameters in org.apache.paimon.flink.source with type arguments of type UnawareAppendCompactionTask

Constructor and Description
AppendBypassCoordinateOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<org.apache.flink.types.Either<CommitT,UnawareAppendCompactionTask>> parameters, FileStoreTable table, org.apache.flink.streaming.runtime.tasks.ProcessingTimeService processingTimeService)

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

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

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

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

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

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

Modifier and Type	Method and Description
byte[]	CompactionTaskSerializer.serialize(UnawareAppendCompactionTask obj)

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

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