Package | Description |
---|---|
org.apache.flink.runtime.execution | |
org.apache.flink.runtime.taskmanager | |
org.apache.flink.state.api.runtime |
Modifier and Type | Method and Description |
---|---|
ThroughputCalculator |
Environment.getThroughputCalculator()
Returns the throughput meter for calculation the throughput for certain period.
|
Modifier and Type | Method and Description |
---|---|
ThroughputCalculator |
RuntimeEnvironment.getThroughputCalculator() |
Constructor and Description |
---|
InputGateWithMetrics(IndexedInputGate inputGate,
Counter numBytesIn,
ThroughputCalculator throughputCalculator) |
RuntimeEnvironment(JobID jobId,
JobVertexID jobVertexId,
ExecutionAttemptID executionId,
ExecutionConfig executionConfig,
TaskInfo taskInfo,
Configuration jobConfiguration,
Configuration taskConfiguration,
UserCodeClassLoader userCodeClassLoader,
MemoryManager memManager,
IOManager ioManager,
BroadcastVariableManager bcVarManager,
TaskStateManager taskStateManager,
GlobalAggregateManager aggregateManager,
AccumulatorRegistry accumulatorRegistry,
TaskKvStateRegistry kvStateRegistry,
InputSplitProvider splitProvider,
Map<String,Future<Path>> distCacheEntries,
ResultPartitionWriter[] writers,
IndexedInputGate[] inputGates,
TaskEventDispatcher taskEventDispatcher,
CheckpointResponder checkpointResponder,
TaskOperatorEventGateway operatorEventGateway,
TaskManagerRuntimeInfo taskManagerInfo,
TaskMetricGroup metrics,
Task containingTask,
ExternalResourceInfoProvider externalResourceInfoProvider,
ThroughputCalculator throughputCalculator) |
Modifier and Type | Method and Description |
---|---|
ThroughputCalculator |
SavepointEnvironment.getThroughputCalculator() |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.