Package | Description |
---|---|
org.apache.flink.runtime.checkpoint | |
org.apache.flink.runtime.executiongraph | |
org.apache.flink.runtime.jobgraph |
Modifier and Type | Method and Description |
---|---|
OperatorID |
OperatorState.getOperatorID() |
Modifier and Type | Method and Description |
---|---|
Map<OperatorID,OperatorState> |
PendingCheckpoint.getOperatorStates() |
Map<OperatorID,OperatorState> |
CompletedCheckpoint.getOperatorStates() |
Constructor and Description |
---|
OperatorState(OperatorID operatorID,
int parallelism,
int maxParallelism) |
Constructor and Description |
---|
CompletedCheckpoint(JobID job,
long checkpointID,
long timestamp,
long completionTimestamp,
Map<OperatorID,OperatorState> operatorStates,
Collection<MasterState> masterHookStates,
CheckpointProperties props,
StreamStateHandle externalizedMetadata,
String externalPointer) |
StateAssignmentOperation(Map<JobVertexID,ExecutionJobVertex> tasks,
Map<OperatorID,OperatorState> operatorStates,
boolean allowNonRestoredState) |
Modifier and Type | Method and Description |
---|---|
List<OperatorID> |
ExecutionJobVertex.getOperatorIDs()
Returns a list containing the IDs of all operators contained in this execution job vertex.
|
List<OperatorID> |
ExecutionJobVertex.getUserDefinedOperatorIDs()
Returns a list containing the alternative IDs of all operators contained in this execution job vertex.
|
static Map<OperatorID,ExecutionJobVertex> |
ExecutionJobVertex.includeAlternativeOperatorIDs(Map<OperatorID,ExecutionJobVertex> operatorMapping) |
Modifier and Type | Method and Description |
---|---|
static Map<OperatorID,ExecutionJobVertex> |
ExecutionJobVertex.includeAlternativeOperatorIDs(Map<OperatorID,ExecutionJobVertex> operatorMapping) |
Modifier and Type | Method and Description |
---|---|
static OperatorID |
OperatorID.fromJobVertexID(JobVertexID id) |
Modifier and Type | Method and Description |
---|---|
List<OperatorID> |
JobVertex.getOperatorIDs() |
List<OperatorID> |
JobVertex.getUserDefinedOperatorIDs() |
Constructor and Description |
---|
InputFormatVertex(String name,
JobVertexID id,
List<JobVertexID> alternativeIds,
List<OperatorID> operatorIds,
List<OperatorID> alternativeOperatorIds) |
InputFormatVertex(String name,
JobVertexID id,
List<JobVertexID> alternativeIds,
List<OperatorID> operatorIds,
List<OperatorID> alternativeOperatorIds) |
JobVertex(String name,
JobVertexID primaryId,
List<JobVertexID> alternativeIds,
List<OperatorID> operatorIds,
List<OperatorID> alternativeOperatorIds)
Constructs a new job vertex and assigns it with the given name.
|
JobVertex(String name,
JobVertexID primaryId,
List<JobVertexID> alternativeIds,
List<OperatorID> operatorIds,
List<OperatorID> alternativeOperatorIds)
Constructs a new job vertex and assigns it with the given name.
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.