@Public public interface InputSplitProvider
InputSplit
objects a
task is supposed to consume in the course of its execution.Modifier and Type | Method and Description |
---|---|
InputSplit |
getNextInputSplit(ClassLoader userCodeClassLoader)
Requests the next input split to be consumed by the calling task.
|
InputSplit getNextInputSplit(ClassLoader userCodeClassLoader) throws InputSplitProviderException
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–2019 The Apache Software Foundation. All rights reserved.