public class TaskInputSplitProvider extends Object implements InputSplitProvider
ActorGateway
to forward the messages.Constructor and Description |
---|
TaskInputSplitProvider(ActorGateway jobManager,
JobID jobID,
JobVertexID vertexID,
ExecutionAttemptID executionID,
scala.concurrent.duration.FiniteDuration timeout) |
Modifier and Type | Method and Description |
---|---|
InputSplit |
getNextInputSplit(ClassLoader userCodeClassLoader)
Requests the next input split to be consumed by the calling task.
|
public TaskInputSplitProvider(ActorGateway jobManager, JobID jobID, JobVertexID vertexID, ExecutionAttemptID executionID, scala.concurrent.duration.FiniteDuration timeout)
public InputSplit getNextInputSplit(ClassLoader userCodeClassLoader) throws InputSplitProviderException
InputSplitProvider
getNextInputSplit
in interface InputSplitProvider
userCodeClassLoader
- used to deserialize input splitsnull
if the
task shall not consume any further input splits.InputSplitProviderException
- if fetching the next input split failsCopyright © 2014–2020 The Apache Software Foundation. All rights reserved.