public interface StreamsFilter
Modifier and Type | Method and Description |
---|---|
boolean |
filter(StreamsDatum entry) |
Queue<StreamsDatum> |
getProcessorInputQueue() |
Queue<StreamsDatum> |
getProcessorOutputQueue() |
void |
setProcessorInputQueue(Queue<StreamsDatum> inputQueue) |
void |
setProcessorOutputQueue(Queue<StreamsDatum> outputQueue) |
void |
start() |
void |
stop() |
void start()
void stop()
void setProcessorInputQueue(Queue<StreamsDatum> inputQueue)
Queue<StreamsDatum> getProcessorInputQueue()
void setProcessorOutputQueue(Queue<StreamsDatum> outputQueue)
Queue<StreamsDatum> getProcessorOutputQueue()
boolean filter(StreamsDatum entry)
Copyright © 2012–2016 The Apache Software Foundation. All rights reserved.