Package org.apache.wayang.java.operators

Class JavaObjectFileSink.StreamChunker

java.lang.Object

org.apache.wayang.java.operators.JavaObjectFileSink.StreamChunker

Enclosing class:

JavaObjectFileSink<T>

public static class JavaObjectFileSink.StreamChunker
extends Object

Utility to chunk a Stream into portions of fixed size.

Constructor Summary

Constructors

Constructor	Description
StreamChunker(int chunkSize, BiConsumer<Object[],Integer> action)

Method Summary

Modifier and Type	Method	Description
void	fire()	Apply the specified action to the current chunk and prepare for a new chunk.
void	push(Object obj)	Add a new element to the current chunk.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

StreamChunker

public StreamChunker(int chunkSize,
 BiConsumer<Object[],Integer> action)

Method Details

push

public void push(Object obj)

Add a new element to the current chunk. Fire, if the chunk is complete.

fire

public void fire()

Apply the specified action to the current chunk and prepare for a new chunk.