I
- Input object typeO
- Input object typepublic abstract class AbstractStreamConversionFilter<I,O> extends AbstractStreamFilter
BundleStreamSource.Event
Modifier and Type | Field and Description |
---|---|
(package private) int |
column
The column to filter
|
(package private) BundleMeta |
meta
The filtered meta
|
source
Constructor and Description |
---|
AbstractStreamConversionFilter() |
Modifier and Type | Method and Description |
---|---|
protected abstract SimpleTypeInformation<? super O> |
convertedType(SimpleTypeInformation<I> in)
Get the output type from the input type after conversion.
|
Object |
data(int rnum)
Access a particular object and representation.
|
protected abstract O |
filterSingleObject(I obj)
Normalize a single instance.
|
protected abstract SimpleTypeInformation<? super I> |
getInputTypeRestriction()
Get the input type restriction used for negotiating the data query.
|
BundleMeta |
getMeta()
Get the current meta data.
|
BundleStreamSource.Event |
nextEvent()
Get the next event
|
filter, init
BundleMeta meta
int column
public BundleMeta getMeta()
BundleStreamSource
public Object data(int rnum)
BundleStreamSource
rnum
- Representation numberpublic BundleStreamSource.Event nextEvent()
BundleStreamSource
protected abstract O filterSingleObject(I obj)
obj
- Database object to normalizeprotected abstract SimpleTypeInformation<? super I> getInputTypeRestriction()
protected abstract SimpleTypeInformation<? super O> convertedType(SimpleTypeInformation<I> in)
in
- input type restriction