public class SplitFetcher<E,SplitT extends SourceSplit> extends Object implements Runnable
Modifier and Type | Method and Description |
---|---|
void |
addSplits(List<SplitT> splitsToAdd)
Add splits to the split fetcher.
|
void |
enqueueTask(SplitFetcherTask task) |
SplitReader<E,SplitT> |
getSplitReader() |
void |
run() |
void |
shutdown()
Shutdown the split fetcher.
|
public void addSplits(List<SplitT> splitsToAdd)
splitsToAdd
- the splits to add.public void enqueueTask(SplitFetcherTask task)
public SplitReader<E,SplitT> getSplitReader()
public void shutdown()
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.