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() |
Set<Map.Entry<OperatorID,OperatorSubtaskState>> |
TaskStateSnapshot.getSubtaskStateMappings()
Returns the set of all mappings from operator id to the corresponding subtask state.
|
Modifier and Type | Method and Description |
---|---|
static Map<OperatorInstanceID,List<OperatorStateHandle>> |
StateAssignmentOperation.applyRepartitioner(OperatorID operatorID,
OperatorStateRepartitioner opStateRepartitioner,
List<OperatorStateHandle> chainOpParallelStates,
int oldParallelism,
int newParallelism) |
OperatorSubtaskState |
TaskStateSnapshot.getSubtaskStateByOperatorID(OperatorID operatorID)
Returns the subtask state for the given operator id (or null if not contained).
|
OperatorSubtaskState |
TaskStateSnapshot.putSubtaskStateByOperatorID(OperatorID operatorID,
OperatorSubtaskState state)
Maps the given operator id to the given subtask state.
|
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,
CompletedCheckpointStorageLocation storageLocation) |
StateAssignmentOperation(long restoreCheckpointId,
Map<JobVertexID,ExecutionJobVertex> tasks,
Map<OperatorID,OperatorState> operatorStates,
boolean allowNonRestoredState) |
TaskStateSnapshot(Map<OperatorID,OperatorSubtaskState> subtaskStatesByOperatorID) |
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) |
OperatorID |
OperatorInstanceID.getOperatorId() |
Modifier and Type | Method and Description |
---|---|
List<OperatorID> |
JobVertex.getOperatorIDs() |
List<OperatorID> |
JobVertex.getUserDefinedOperatorIDs() |
Modifier and Type | Method and Description |
---|---|
static OperatorInstanceID |
OperatorInstanceID.of(int subtaskId,
OperatorID operatorID) |
Constructor and Description |
---|
OperatorInstanceID(int subtaskId,
OperatorID operatorId) |
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.
|
Modifier and Type | Method and Description |
---|---|
OperatorMetricGroup |
UnregisteredMetricGroups.UnregisteredTaskMetricGroup.addOperator(OperatorID operatorID,
String name) |
OperatorMetricGroup |
TaskMetricGroup.addOperator(OperatorID operatorID,
String name) |
Constructor and Description |
---|
OperatorMetricGroup(MetricRegistry registry,
TaskMetricGroup parent,
OperatorID operatorID,
String operatorName) |
Modifier and Type | Method and Description |
---|---|
String[] |
OperatorScopeFormat.formatScope(TaskMetricGroup parent,
OperatorID operatorID,
String operatorName) |
Modifier and Type | Method and Description |
---|---|
PrioritizedOperatorSubtaskState |
TaskStateManager.prioritizedOperatorState(OperatorID operatorID)
Returns means to restore previously reported state of an operator running in the owning task.
|
PrioritizedOperatorSubtaskState |
TaskStateManagerImpl.prioritizedOperatorState(OperatorID operatorID) |
Constructor and Description |
---|
OperatorSubtaskDescriptionText(OperatorID operatorId,
String operatorClass,
int subtaskIndex,
int numberOfTasks) |
Modifier and Type | Method and Description |
---|---|
OperatorID |
StreamConfig.getOperatorID() |
Modifier and Type | Method and Description |
---|---|
void |
StreamConfig.setOperatorID(OperatorID operatorID) |
Modifier and Type | Method and Description |
---|---|
OperatorID |
StreamOperator.getOperatorID() |
OperatorID |
AbstractStreamOperator.getOperatorID() |
Modifier and Type | Method and Description |
---|---|
StreamOperatorStateContext |
StreamTaskStateInitializerImpl.streamOperatorStateContext(OperatorID operatorID,
String operatorClassName,
KeyContext keyContext,
TypeSerializer<?> keySerializer,
CloseableRegistry streamTaskCloseableRegistry) |
StreamOperatorStateContext |
StreamTaskStateInitializer.streamOperatorStateContext(OperatorID operatorID,
String operatorClassName,
KeyContext keyContext,
TypeSerializer<?> keySerializer,
CloseableRegistry streamTaskCloseableRegistry)
Returns the
StreamOperatorStateContext for an AbstractStreamOperator that runs in the stream
task that owns this manager. |
Modifier and Type | Method and Description |
---|---|
OperatorID |
LatencyMarker.getOperatorId() |
Constructor and Description |
---|
LatencyMarker(long markedTime,
OperatorID operatorId,
int subtaskIndex)
Creates a latency mark with the given timestamp.
|
Constructor and Description |
---|
LatencyStats(MetricGroup metricGroup,
int historySize,
int subtaskIndex,
OperatorID operatorID,
LatencyStats.Granularity granularity) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.