public abstract class XBTokenOperator<T,U>
extends java.lang.Object
| Constructor and Description |
|---|
XBTokenOperator() |
| Modifier and Type | Method and Description |
|---|---|
abstract int |
availableInput()
Get available capacity of input buffer
|
abstract int |
availableOutput()
Get available capacity of output buffer
|
abstract T |
getToken()
Get single event from source
|
abstract void |
putToken(U event)
Put single processed event
|
abstract void |
request(int count)
Set request for minimum cache fill to operate
|
abstract void |
reset()
Reset processing
|
abstract void |
setInputCache(int size)
Set size of operator's input cache
|
abstract void |
setOutputCache(int size)
Set size of operator's output cache
|
public abstract void putToken(U event) throws java.io.IOException
java.io.IOExceptionpublic abstract T getToken() throws java.io.IOException
java.io.IOExceptionpublic abstract void reset()
public abstract int availableInput()
public abstract int availableOutput()
public abstract void request(int count)
public abstract void setInputCache(int size)
public abstract void setOutputCache(int size)