Page History

@PublicEvolving@Internal
public class FetchTask<ESplitFetcher<E, SplitT extends SourceSplit> implements SplitFetcherTaskRunnable {
    private final SplitReader<E, SplitT> splitReader;
    private final FutureCompletingBlockingQueue<RecordsWithSplitIds<E>> elementsQueue;   
	SplitFetcher(
    private final Consumer<Collection<String>> splitFinishedCallback;
    private final int fetcherIndex;
    private volatile RecordsWithSplitIds<E> lastRecords;
    private volatile boolean wakeup;

    FetchTask(
            SplitReader<E, SplitT> splitReader,
            FutureCompletingBlockingQueue<RecordsWithSplitIds<E>> elementsQueue,
            Consumer<Collection<String>> splitFinishedCallback,
id,
            FutureCompletingBlockingQueue<RecordsWithSplitIds<E>> elementsQueue,
  int fetcherIndex) {
        this.splitReader =SplitReader<E, SplitT> splitReader;,
        this.elementsQueue = elementsQueue;
  Consumer<Throwable>  errorHandler,
    this.splitFinishedCallback = splitFinishedCallback;
      Runnable shutdownHook,
 this.lastRecords = null;
        this.fetcherIndex =Consumer<Collection<String>> fetcherIndex;splitFinishedHook,
        this.wakeup = false;
  boolean  }allowUnalignedSourceSplits);
}