org.apache.flink.table.filesystem.stream.compact

Class CompactMessages.CompactionUnit

java.lang.Object

org.apache.flink.table.filesystem.stream.compact.CompactMessages.CompactionUnit

All Implemented Interfaces:

Serializable, CompactMessages.CoordinatorOutput

Enclosing class:

CompactMessages

public static class CompactMessages.CompactionUnit
extends Object
implements CompactMessages.CoordinatorOutput

The unit of a single compaction.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
CompactionUnit(int unitId, String partition, List<Path> unit)

Method Summary

Modifier and Type	Method and Description
String	getPartition()
List<Path>	getPaths()
int	getUnitId()
boolean	isTaskMessage(int taskNumber, int taskId)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CompactionUnit

public CompactionUnit(int unitId,
                      String partition,
                      List<Path> unit)

Method Detail

isTaskMessage

public boolean isTaskMessage(int taskNumber,
                             int taskId)

getUnitId

public int getUnitId()

getPartition

public String getPartition()

getPaths

public List<Path> getPaths()