CompactMessages.CompactionUnit (Flink : 2.0-SNAPSHOT API)

java.lang.Object
- org.apache.flink.connector.file.table.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 Description

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

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	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()
```