Uses of Interface
org.apache.flink.connector.file.table.stream.compact.CompactMessages.CoordinatorOutput

Packages that use CompactMessages.CoordinatorOutput

Package	Description
org.apache.flink.connector.file.table.batch.compact
org.apache.flink.connector.file.table.stream.compact

Uses of CompactMessages.CoordinatorOutput in org.apache.flink.connector.file.table.batch.compact

Method parameters in org.apache.flink.connector.file.table.batch.compact with type arguments of type CompactMessages.CoordinatorOutput

Modifier and Type	Method	Description
void	BatchCompactOperator.processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<CompactMessages.CoordinatorOutput> element)

Uses of CompactMessages.CoordinatorOutput in org.apache.flink.connector.file.table.stream.compact

Classes in org.apache.flink.connector.file.table.stream.compact that implement CompactMessages.CoordinatorOutput

Modifier and Type	Class	Description
static class	CompactMessages.CompactionUnit	The unit of a single compaction.
static class	CompactMessages.EndCompaction	A flag to end compaction.

Method parameters in org.apache.flink.connector.file.table.stream.compact with type arguments of type CompactMessages.CoordinatorOutput

Modifier and Type	Method	Description
void	CompactOperator.processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<CompactMessages.CoordinatorOutput> element)