public class TaskInputSplitProvider extends Object implements InputSplitProvider
Constructor and Description |
---|
TaskInputSplitProvider(ActorGateway jobManager,
JobID jobId,
JobVertexID vertexId,
ExecutionAttemptID executionID,
ClassLoader userCodeClassLoader,
scala.concurrent.duration.FiniteDuration timeout) |
Modifier and Type | Method and Description |
---|---|
InputSplit |
getNextInputSplit()
Requests the next input split to be consumed by the calling task.
|
public TaskInputSplitProvider(ActorGateway jobManager, JobID jobId, JobVertexID vertexId, ExecutionAttemptID executionID, ClassLoader userCodeClassLoader, scala.concurrent.duration.FiniteDuration timeout)
public InputSplit getNextInputSplit()
InputSplitProvider
getNextInputSplit
in interface InputSplitProvider
null
if the
task shall not consume any further input splits.Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.