@Internal public class RemoveSplitsTask<SplitT extends SourceSplit> extends Object implements SplitFetcherTask
Modifier and Type | Method and Description |
---|---|
boolean |
run()
Run the logic.
|
String |
toString() |
void |
wakeUp()
Wake up the running thread.
|
public boolean run()
SplitFetcherTask
run
in interface SplitFetcherTask
public void wakeUp()
SplitFetcherTask
wakeUp
in interface SplitFetcherTask
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.