public class Checkpoint extends java.lang.Object implements EmittedItem, Metadata
Modifier and Type | Class and Description |
---|---|
static class |
Checkpoint.Builder |
static class |
Checkpoint.Emitter |
Modifier and Type | Method and Description |
---|---|
static Checkpoint.Builder |
builder(java.lang.String id) |
static Checkpoint.Emitter |
emitter(java.lang.String id,
java.util.function.Consumer<EmittedItem> emittedItemConsumer)
Creates a new checkpoint emitter
|
java.lang.String |
getBlockId()
Deprecated.
- Internal use only; will be removed.
|
long |
getBlockStartTime()
Deprecated.
- Internal use only; will be removed.
|
java.lang.String |
getId() |
java.util.Map<java.lang.String,java.lang.Object> |
getMetadata() |
java.lang.String |
getParentId() |
java.lang.String |
getSourcePhase() |
java.lang.String |
getTargetPhase() |
java.lang.String |
toString() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
hasMetadata
public java.lang.String getId()
getId
in interface Identifiable
public java.lang.String getParentId()
public java.lang.String getTargetPhase()
public java.lang.String getSourcePhase()
@Deprecated public java.lang.String getBlockId()
@Deprecated public long getBlockStartTime()
public java.util.Map<java.lang.String,java.lang.Object> getMetadata()
getMetadata
in interface Metadata
public static Checkpoint.Builder builder(java.lang.String id)
public static Checkpoint.Emitter emitter(java.lang.String id, java.util.function.Consumer<EmittedItem> emittedItemConsumer)
id
- idemittedItemConsumer
- emitted item consumerpublic java.lang.String toString()
toString
in class java.lang.Object