I
- Input typeO
- Output typepublic class ProjectionFilter<I,O> extends AbstractStreamConversionFilter<I,O>
Modifier and Type | Class and Description |
---|---|
static class |
ProjectionFilter.Parameterizer<I,O>
Parameterization class.
|
BundleStreamSource.Event
Modifier and Type | Field and Description |
---|---|
(package private) Projection<I,O> |
projection
Projection to apply.
|
source
Constructor and Description |
---|
ProjectionFilter(Projection<I,O> projection)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
protected SimpleTypeInformation<? super O> |
convertedType(SimpleTypeInformation<I> in)
Get the output type from the input type after conversion.
|
protected O |
filterSingleObject(I obj)
Normalize a single instance.
|
protected TypeInformation |
getInputTypeRestriction()
Get the input type restriction used for negotiating the data query.
|
data, getMeta, nextEvent
filter, init
Projection<I,O> projection
public ProjectionFilter(Projection<I,O> projection)
projection
- Projectionprotected O filterSingleObject(I obj)
AbstractStreamConversionFilter
filterSingleObject
in class AbstractStreamConversionFilter<I,O>
obj
- Database object to normalizeprotected TypeInformation getInputTypeRestriction()
AbstractStreamConversionFilter
getInputTypeRestriction
in class AbstractStreamConversionFilter<I,O>
protected SimpleTypeInformation<? super O> convertedType(SimpleTypeInformation<I> in)
AbstractStreamConversionFilter
convertedType
in class AbstractStreamConversionFilter<I,O>
in
- input type restriction