Package | Description |
---|---|
org.apache.flink.runtime.jobmaster | |
org.apache.flink.runtime.scheduler | |
org.apache.flink.runtime.scheduler.adaptive |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<SerializedInputSplit> |
JobMaster.requestNextInputSplit(JobVertexID vertexID,
ExecutionAttemptID executionAttempt) |
CompletableFuture<SerializedInputSplit> |
JobMasterGateway.requestNextInputSplit(JobVertexID vertexID,
ExecutionAttemptID executionAttempt)
Requests the next input split for the
ExecutionJobVertex . |
Modifier and Type | Method and Description |
---|---|
SerializedInputSplit |
SchedulerBase.requestNextInputSplit(JobVertexID vertexID,
ExecutionAttemptID executionAttempt) |
SerializedInputSplit |
ExecutionGraphHandler.requestNextInputSplit(JobVertexID vertexID,
ExecutionAttemptID executionAttempt) |
SerializedInputSplit |
SchedulerNG.requestNextInputSplit(JobVertexID vertexID,
ExecutionAttemptID executionAttempt) |
Modifier and Type | Method and Description |
---|---|
SerializedInputSplit |
AdaptiveScheduler.requestNextInputSplit(JobVertexID vertexID,
ExecutionAttemptID executionAttempt) |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.