StreamFilter (Flink : 2.0-SNAPSHOT API)

java.lang.Object
- org.apache.flink.streaming.api.operators.AbstractStreamOperator<OUT>
- - org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator<IN,FilterFunction<IN>>
  - - org.apache.flink.streaming.api.operators.StreamFilter<IN>

All Implemented Interfaces:

Serializable, CheckpointListener, Input<IN>, KeyContext, KeyContextHandler, OneInputStreamOperator<IN,IN>, OutputTypeConfigurable<IN>, StreamOperator<IN>, StreamOperatorStateHandler.CheckpointedStreamOperator, UserFunctionProvider<FilterFunction<IN>>, YieldingOperator<IN>
```
@Internal
public class StreamFilter<IN>
extends AbstractUdfStreamOperator<IN,FilterFunction<IN>>
implements OneInputStreamOperator<IN,IN>
```
A StreamOperator for executing FilterFunctions.

See Also:

Serialized Form

Field Summary
- Fields inherited from class org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator
  userFunction
- Fields inherited from class org.apache.flink.streaming.api.operators.AbstractStreamOperator
  config, lastRecordAttributes1, lastRecordAttributes2, latencyStats, LOG, metrics, output, processingTimeService, stateHandler, stateKeySelector1, stateKeySelector2, timeServiceManager

Constructor Summary

Constructors
Constructor Description

StreamFilter(FilterFunction<IN> filterFunction)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`processElement(StreamRecord<IN> element)`	Processes one element that arrived on this input of the `MultipleInputStreamOperator`.

Methods inherited from class org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator
close, finish, getUserFunction, getUserFunctionParameters, initializeState, notifyCheckpointAborted, notifyCheckpointComplete, open, setOutputType, setup, snapshotState

Methods inherited from class org.apache.flink.streaming.api.operators.AbstractStreamOperator
getContainingTask, getCurrentKey, getExecutionConfig, getInternalTimerService, getKeyedStateBackend, getKeyedStateStore, getMetricGroup, getOperatorConfig, getOperatorID, getOperatorName, getOperatorStateBackend, getOrCreateKeyedState, getPartitionedState, getPartitionedState, getProcessingTimeService, getRuntimeContext, getStateKeySelector1, getStateKeySelector2, getTimeServiceManager, getUserCodeClassloader, hasKeyContext1, hasKeyContext2, initializeState, isUsingCustomRawKeyedState, prepareSnapshotPreBarrier, processLatencyMarker, processLatencyMarker1, processLatencyMarker2, processRecordAttributes, processRecordAttributes1, processRecordAttributes2, processWatermark, processWatermark1, processWatermark2, processWatermarkStatus, processWatermarkStatus1, processWatermarkStatus2, reportOrForwardLatencyMarker, setCurrentKey, setKeyContextElement1, setKeyContextElement2, setMailboxExecutor, setProcessingTimeService, snapshotState, useSplittableTimers

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.api.common.state.CheckpointListener
notifyCheckpointAborted, notifyCheckpointComplete

Methods inherited from interface org.apache.flink.streaming.api.operators.Input
processLatencyMarker, processRecordAttributes, processWatermark, processWatermarkStatus

Methods inherited from interface org.apache.flink.streaming.api.operators.KeyContext
getCurrentKey, setCurrentKey

Methods inherited from interface org.apache.flink.streaming.api.operators.KeyContextHandler
hasKeyContext

Methods inherited from interface org.apache.flink.streaming.api.operators.OneInputStreamOperator
setKeyContextElement

Methods inherited from interface org.apache.flink.streaming.api.operators.StreamOperator
close, finish, getMetricGroup, getOperatorAttributes, getOperatorID, initializeState, open, prepareSnapshotPreBarrier, setKeyContextElement1, setKeyContextElement2, snapshotState

- Constructor Detail
  - StreamFilter
```
public StreamFilter(FilterFunction<IN> filterFunction)
```
- Method Detail
  - processElement
```
public void processElement(StreamRecord<IN> element)
                    throws Exception
```
    Description copied from interface: Input
    
    Processes one element that arrived on this input of the MultipleInputStreamOperator. This method is guaranteed to not be called concurrently with other methods of the operator.
    
    Specified by:
    
    processElement in interface Input<IN>
    
    Throws:
    
    Exception