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<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.
|
Modifier and Type | Method and Description |
---|---|
static void |
StateAssignmentOperation.reDistributePartitionableStates(List<OperatorState> oldOperatorStates,
int newParallelism,
List<OperatorID> newOperatorIDs,
Map<OperatorInstanceID,List<OperatorStateHandle>> newManagedOperatorStates,
Map<OperatorInstanceID,List<OperatorStateHandle>> newRawOperatorStates) |
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,
Set<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 |
---|---|
Map<OperatorID,UserCodeWrapper<? extends InputFormat<?,?>>> |
InputOutputFormatContainer.getInputFormats() |
Map<OperatorID,UserCodeWrapper<? extends InputFormat<?,?>>> |
InputOutputFormatContainer.FormatUserCodeTable.getInputFormats() |
List<OperatorID> |
JobVertex.getOperatorIDs() |
Map<OperatorID,UserCodeWrapper<? extends OutputFormat<?>>> |
InputOutputFormatContainer.getOutputFormats() |
Map<OperatorID,UserCodeWrapper<? extends OutputFormat<?>>> |
InputOutputFormatContainer.FormatUserCodeTable.getOutputFormats() |
<OT,T extends InputSplit> |
InputOutputFormatContainer.getUniqueInputFormat() |
<IT> org.apache.commons.lang3.tuple.Pair<OperatorID,OutputFormat<IT>> |
InputOutputFormatContainer.getUniqueOutputFormat() |
List<OperatorID> |
JobVertex.getUserDefinedOperatorIDs() |
Modifier and Type | Method and Description |
---|---|
InputOutputFormatContainer |
InputOutputFormatContainer.addInputFormat(OperatorID operatorId,
InputFormat<?,?> inputFormat) |
InputOutputFormatContainer |
InputOutputFormatContainer.addInputFormat(OperatorID operatorId,
UserCodeWrapper<? extends InputFormat<?,?>> wrapper) |
void |
InputOutputFormatContainer.FormatUserCodeTable.addInputFormat(OperatorID operatorId,
UserCodeWrapper<? extends InputFormat<?,?>> wrapper) |
InputOutputFormatContainer |
InputOutputFormatContainer.addOutputFormat(OperatorID operatorId,
OutputFormat<?> outputFormat) |
InputOutputFormatContainer |
InputOutputFormatContainer.addOutputFormat(OperatorID operatorId,
UserCodeWrapper<? extends OutputFormat<?>> wrapper) |
void |
InputOutputFormatContainer.FormatUserCodeTable.addOutputFormat(OperatorID operatorId,
UserCodeWrapper<? extends OutputFormat<?>> wrapper) |
InputOutputFormatContainer |
InputOutputFormatContainer.addParameters(OperatorID operatorId,
Configuration parameters) |
InputOutputFormatContainer |
InputOutputFormatContainer.addParameters(OperatorID operatorId,
String key,
String value) |
String |
InputOutputFormatVertex.getFormatDescription(OperatorID operatorID) |
Configuration |
InputOutputFormatContainer.getParameters(OperatorID operatorId) |
static OperatorInstanceID |
OperatorInstanceID.of(int subtaskId,
OperatorID operatorID) |
void |
InputOutputFormatVertex.setFormatDescription(OperatorID operatorID,
String formatDescription) |
Constructor and Description |
---|
OperatorInstanceID(int subtaskId,
OperatorID operatorId) |
Constructor and Description |
---|
InputOutputFormatVertex(String name,
JobVertexID id,
List<JobVertexID> alternativeIds,
List<OperatorID> operatorIds,
List<OperatorID> alternativeOperatorIds) |
InputOutputFormatVertex(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.getOrAddOperator(OperatorID operatorID,
String name) |
OperatorMetricGroup |
TaskMetricGroup.getOrAddOperator(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) |
Constructor and Description |
---|
OperatorSubtaskStateReducer(OperatorID operatorID,
int maxParallelism) |
Modifier and Type | Method and Description |
---|---|
static OperatorID |
OperatorIDGenerator.fromUid(String uid)
Generate
OperatorID 's from uid 's. |
OperatorID |
BootstrapTransformationWithID.getOperatorID() |
Constructor and Description |
---|
BootstrapTransformationWithID(OperatorID operatorID,
BootstrapTransformation<T> bootstrapTransformation) |
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,
ProcessingTimeService processingTimeService,
KeyContext keyContext,
TypeSerializer<?> keySerializer,
CloseableRegistry streamTaskCloseableRegistry,
MetricGroup metricGroup) |
StreamOperatorStateContext |
StreamTaskStateInitializer.streamOperatorStateContext(OperatorID operatorID,
String operatorClassName,
ProcessingTimeService processingTimeService,
KeyContext keyContext,
TypeSerializer<?> keySerializer,
CloseableRegistry streamTaskCloseableRegistry,
MetricGroup metricGroup)
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.