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

Class CompactMessages.EndCheckpoint

java.lang.Object

org.apache.flink.connector.file.table.stream.compact.CompactMessages.EndCheckpoint

All Implemented Interfaces:

Serializable, CompactMessages.CoordinatorInput

Enclosing class:

CompactMessages

public static class CompactMessages.EndCheckpoint
extends Object
implements CompactMessages.CoordinatorInput

A flag to end checkpoint, coordinator can start coordinating one checkpoint.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
EndCheckpoint(long checkpointId, int taskId, int numberOfTasks)

Method Summary

Modifier and Type	Method	Description
long	getCheckpointId()
int	getNumberOfTasks()
int	getTaskId()

Methods inherited from class java.lang.Object

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

Constructor Detail

EndCheckpoint

public EndCheckpoint(long checkpointId,
                     int taskId,
                     int numberOfTasks)

Method Detail

getCheckpointId

public long getCheckpointId()

getTaskId

public int getTaskId()

getNumberOfTasks

public int getNumberOfTasks()