T
- Record Type.E
- Extra message of one RecordReader
.public class ParallelExecution<T,E> extends Object implements Closeable
Modifier and Type | Class and Description |
---|---|
static interface |
ParallelExecution.ParallelBatch<T,E>
A batch provides next and extra message.
|
Constructor and Description |
---|
ParallelExecution(Serializer<T> serializer,
int pageSize,
int parallelism,
List<java.util.function.Supplier<Pair<RecordReader<T>,E>>> readers) |
public ParallelExecution(Serializer<T> serializer, int pageSize, int parallelism, List<java.util.function.Supplier<Pair<RecordReader<T>,E>>> readers)
@Nullable public ParallelExecution.ParallelBatch<T,E> take() throws InterruptedException, IOException
InterruptedException
IOException
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
IOException
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.