Modifier and Type | Method and Description |
---|---|
TaskEventDispatcher |
Environment.getTaskEventDispatcher() |
Modifier and Type | Method and Description |
---|---|
TaskEventDispatcher |
NetworkEnvironment.getTaskEventDispatcher() |
Modifier and Type | Method and Description |
---|---|
void |
ConnectionManager.start(ResultPartitionProvider partitionProvider,
TaskEventDispatcher taskEventDispatcher) |
void |
LocalConnectionManager.start(ResultPartitionProvider partitionProvider,
TaskEventDispatcher taskEventDispatcher) |
Constructor and Description |
---|
NetworkEnvironment(NetworkBufferPool networkBufferPool,
ConnectionManager connectionManager,
ResultPartitionManager resultPartitionManager,
TaskEventDispatcher taskEventDispatcher,
KvStateRegistry kvStateRegistry,
KvStateServer kvStateServer,
KvStateClientProxy kvStateClientProxy,
IOManager.IOMode defaultIOMode,
int partitionRequestInitialBackoff,
int partitionRequestMaxBackoff,
int networkBuffersPerChannel,
int extraNetworkBuffersPerGate,
boolean enableCreditBased) |
Modifier and Type | Method and Description |
---|---|
void |
NettyConnectionManager.start(ResultPartitionProvider partitionProvider,
TaskEventDispatcher taskEventDispatcher) |
Constructor and Description |
---|
LocalInputChannel(SingleInputGate inputGate,
int channelIndex,
ResultPartitionID partitionId,
ResultPartitionManager partitionManager,
TaskEventDispatcher taskEventDispatcher,
int initialBackoff,
int maxBackoff,
TaskIOMetricGroup metrics) |
LocalInputChannel(SingleInputGate inputGate,
int channelIndex,
ResultPartitionID partitionId,
ResultPartitionManager partitionManager,
TaskEventDispatcher taskEventDispatcher,
TaskIOMetricGroup metrics) |
Modifier and Type | Method and Description |
---|---|
TaskEventDispatcher |
RuntimeEnvironment.getTaskEventDispatcher() |
Constructor and Description |
---|
RuntimeEnvironment(JobID jobId,
JobVertexID jobVertexId,
ExecutionAttemptID executionId,
ExecutionConfig executionConfig,
TaskInfo taskInfo,
Configuration jobConfiguration,
Configuration taskConfiguration,
ClassLoader userCodeClassLoader,
MemoryManager memManager,
IOManager ioManager,
BroadcastVariableManager bcVarManager,
TaskStateManager taskStateManager,
AccumulatorRegistry accumulatorRegistry,
TaskKvStateRegistry kvStateRegistry,
InputSplitProvider splitProvider,
Map<String,Future<Path>> distCacheEntries,
ResultPartitionWriter[] writers,
InputGate[] inputGates,
TaskEventDispatcher taskEventDispatcher,
CheckpointResponder checkpointResponder,
TaskManagerRuntimeInfo taskManagerInfo,
TaskMetricGroup metrics,
Task containingTask) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.