Uses of Class
org.apache.paimon.flink.compact.changelog.ChangelogCompactTask

Packages that use ChangelogCompactTask

Package	Description
org.apache.paimon.flink.compact.changelog

Uses of ChangelogCompactTask in org.apache.paimon.flink.compact.changelog

Methods in org.apache.paimon.flink.compact.changelog that return ChangelogCompactTask

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

Methods in org.apache.paimon.flink.compact.changelog that return types with arguments of type ChangelogCompactTask

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

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

Modifier and Type	Method and Description
byte[]	ChangelogCompactTaskSerializer.serialize(ChangelogCompactTask obj)

Method parameters in org.apache.paimon.flink.compact.changelog with type arguments of type ChangelogCompactTask

Modifier and Type	Method and Description
void	ChangelogCompactWorkerOperator.processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<org.apache.flink.types.Either<Committable,ChangelogCompactTask>> record)