public interface ConnectorSplitSource extends Closeable
| Modifier and Type | Method and Description |
|---|---|
void |
close() |
String |
getDataSourceName() |
CompletableFuture<List<ConnectorSplit>> |
getNextBatch(int maxSize) |
boolean |
isFinished() |
String getDataSourceName()
CompletableFuture<List<ConnectorSplit>> getNextBatch(int maxSize)
void close()
close in interface AutoCloseableclose in interface Closeableboolean isFinished()
Copyright © 2012-2016. All Rights Reserved.