Package | Description |
---|---|
org.apache.flink.api.java.operators | |
org.apache.flink.api.java.operators.translation | |
org.apache.flink.optimizer.dag |
Modifier and Type | Method and Description |
---|---|
protected FilterOperatorBase<T,FlatMapFunction<T,T>> |
FilterOperator.translateToDataFlow(Operator<T> input) |
Modifier and Type | Class and Description |
---|---|
class |
PlanFilterOperator<T> |
Modifier and Type | Method and Description |
---|---|
FilterOperatorBase<?,?> |
FilterNode.getOperator() |
Constructor and Description |
---|
FilterNode(FilterOperatorBase<?,?> operator) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.