com.neurosys.etl.processors.batch

Class SerialBufferSplitter<T>

java.lang.Object

com.neurosys.etl.process.EventAwareProcess

com.neurosys.etl.processors.batch.SerialBufferSplitter<T>

All Implemented Interfaces:

Process, BufferSplitter<T>, Serializable

public abstract class SerialBufferSplitter<T>
extends EventAwareProcess
implements BufferSplitter<T>

A splitter that chunks up a Larger List or Stream into Smaller buffers serially and synchronously with an added option for CheckCallback before dispatching the next batch.

Author:

Arjun Dhar

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface com.neurosys.etl.process.Process

Process.Event, Process.EventPoint

Field Summary

Fields

Modifier and Type	Field and Description
protected int	batchSize

Fields inherited from class com.neurosys.etl.process.EventAwareProcess

listeners, processState

Constructor Summary

Constructors

Constructor and Description
SerialBufferSplitter(List<T> largeBatch, int batchSize)
SerialBufferSplitter(ObjectInputStream ois, int batchSize)

Method Summary

Modifier and Type	Method and Description
int	getBatchSize()
void	killProcess(boolean process) Applicable when processing streams, if false then the stream processing will end and so will the lifecycle of the object
abstract void	processBatch(List<T> batch) Callback on the batch created as a result of this process
void	setBatchSize(int batchSize)

Methods inherited from class com.neurosys.etl.process.EventAwareProcess

addListener, getListeners, onChangeHandler, setListeners

Methods inherited from class java.lang.Object

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

Field Detail

batchSize

protected int batchSize

Constructor Detail

SerialBufferSplitter

public SerialBufferSplitter(ObjectInputStream ois,
                            int batchSize)
                     throws IOException,
                            ClassNotFoundException

Throws:

IOException

ClassNotFoundException

SerialBufferSplitter

public SerialBufferSplitter(List<T> largeBatch,
                            int batchSize)

Method Detail

processBatch

public abstract void processBatch(List<T> batch)

Callback on the batch created as a result of this process

Specified by:

processBatch in interface BufferSplitter<T>

Parameters:

batch - as List

getBatchSize

public int getBatchSize()

setBatchSize

public void setBatchSize(int batchSize)

killProcess

public void killProcess(boolean process)

Applicable when processing streams, if false then the stream processing will end and so will the lifecycle of the object