org.apache.paimon.utils

Interface ParallelExecution.ParallelBatch<T,E>

Enclosing class:

ParallelExecution<T,E>

public static interface ParallelExecution.ParallelBatch<T,E>

A batch provides next and extra message.

Method Summary

Modifier and Type	Method and Description
E	extraMessage()
T	next()
void	releaseBatch()

Method Detail

next

@Nullable
T next()
          throws IOException

Throws:

IOException

releaseBatch

void releaseBatch()

extraMessage

E extraMessage()