Package | Description |
---|---|
org.apache.flink.runtime.execution | |
org.apache.flink.runtime.jobgraph.tasks | |
org.apache.flink.runtime.taskmanager | |
org.apache.flink.streaming.api.operators |
Modifier and Type | Method and Description |
---|---|
InputSplitProvider |
Environment.getInputSplitProvider()
Returns the input split provider assigned to this environment.
|
Constructor and Description |
---|
InputSplitIterator(InputSplitProvider inputSplitProvider)
Constructs a new input split iterator.
|
Modifier and Type | Class and Description |
---|---|
class |
TaskInputSplitProvider |
Modifier and Type | Method and Description |
---|---|
InputSplitProvider |
RuntimeEnvironment.getInputSplitProvider() |
Constructor and Description |
---|
RuntimeEnvironment(JobID jobId,
JobVertexID jobVertexId,
ExecutionAttemptID executionId,
TaskInfo taskInfo,
Configuration jobConfiguration,
Configuration taskConfiguration,
ClassLoader userCodeClassLoader,
MemoryManager memManager,
IOManager ioManager,
BroadcastVariableManager bcVarManager,
AccumulatorRegistry accumulatorRegistry,
InputSplitProvider splitProvider,
Map<String,Future<Path>> distCacheEntries,
ResultPartitionWriter[] writers,
InputGate[] inputGates,
ActorGateway jobManager,
TaskManagerRuntimeInfo taskManagerInfo) |
Modifier and Type | Method and Description |
---|---|
InputSplitProvider |
StreamingRuntimeContext.getInputSplitProvider()
Returns the input split provider associated with the operator.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.