public abstract class SerialBufferSplitter<T> extends EventAwareProcess implements BufferSplitter<T>
Process.Event, Process.EventPoint
Modifier and Type | Field and Description |
---|---|
protected int |
batchSize |
listeners, processState
Constructor and Description |
---|
SerialBufferSplitter(List<T> largeBatch,
int batchSize) |
SerialBufferSplitter(ObjectInputStream ois,
int batchSize) |
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) |
addListener, getListeners, onChangeHandler, setListeners
public SerialBufferSplitter(ObjectInputStream ois, int batchSize) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
public abstract void processBatch(List<T> batch)
processBatch
in interface BufferSplitter<T>
batch
- as List
public int getBatchSize()
public void setBatchSize(int batchSize)
public void killProcess(boolean process)
Copyright © 2018. All rights reserved.