Package org.apache.flink.streaming.api.connector.sink2

Class CommittableSummary<CommT>

java.lang.Object

org.apache.flink.streaming.api.connector.sink2.CommittableSummary<CommT>

Type Parameters:

CommT - type of the committable

All Implemented Interfaces:

CommittableMessage<CommT>

@Experimental
public class CommittableSummary<CommT>
extends Object
implements CommittableMessage<CommT>

This class tracks the information about committables belonging to one checkpoint coming from one subtask.

It is sent to down-stream consumers to depict the progress of the committing process.

Constructor Summary

Constructors

Constructor	Description
CommittableSummary(int subtaskId, int numberOfSubtasks, Long checkpointId, int numberOfCommittables, int numberOfPendingCommittables, int numberOfFailedCommittables)

Method Summary

Modifier and Type	Method	Description
OptionalLong	getCheckpointId()	Returns the checkpoint id or empty if the message does not belong to a checkpoint.
int	getNumberOfCommittables()
int	getNumberOfFailedCommittables()
int	getNumberOfPendingCommittables()
int	getNumberOfSubtasks()
int	getSubtaskId()	The subtask that created this committable.

Methods inherited from class java.lang.Object

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

Constructor Detail

CommittableSummary

public CommittableSummary(int subtaskId,
                          int numberOfSubtasks,
                          @Nullable
                          Long checkpointId,
                          int numberOfCommittables,
                          int numberOfPendingCommittables,
                          int numberOfFailedCommittables)

Method Detail

getSubtaskId

public int getSubtaskId()

Description copied from interface: CommittableMessage

The subtask that created this committable.

Specified by:

getSubtaskId in interface CommittableMessage<CommT>

getNumberOfSubtasks

public int getNumberOfSubtasks()

getCheckpointId

public OptionalLong getCheckpointId()

Description copied from interface: CommittableMessage

Returns the checkpoint id or empty if the message does not belong to a checkpoint. In that case, the committable was created at the end of input (e.g., in batch mode).

Specified by:

getCheckpointId in interface CommittableMessage<CommT>

getNumberOfCommittables

public int getNumberOfCommittables()

getNumberOfPendingCommittables

public int getNumberOfPendingCommittables()

getNumberOfFailedCommittables

public int getNumberOfFailedCommittables()