public interface StreamsProcessor extends StreamsOperation
Modifier and Type | Method and Description |
---|---|
List<StreamsDatum> |
process(StreamsDatum entry)
Process/Analyze the
StreamsDatum and return the the StreamsDatums that will
passed to every down stream operation that reads from this processor. |
cleanUp, getId, prepare
List<StreamsDatum> process(StreamsDatum entry)
StreamsDatum
and return the the StreamsDatums that will
passed to every down stream operation that reads from this processor.entry
- StreamsDatum to be processedCopyright © 2017 The Apache Software Foundation. All rights reserved.