Modifier and Type | Class and Description |
---|---|
class |
RichFilterFunction<T>
Rich variant of the
FilterFunction . |
Modifier and Type | Method and Description |
---|---|
FilterOperator<T> |
DataSet.filter(FilterFunction<T> filter)
Applies a Filter transformation on a
DataSet . |
Modifier and Type | Field and Description |
---|---|
protected FilterFunction<T> |
FilterOperator.function |
Modifier and Type | Method and Description |
---|---|
protected FilterFunction<T> |
FilterOperator.getFunction() |
Constructor and Description |
---|
FilterOperator(DataSet<T> input,
FilterFunction<T> function,
String defaultName) |
Constructor and Description |
---|
PlanFilterOperator(FilterFunction<T> udf,
String name,
TypeInformation<T> type) |
Modifier and Type | Class and Description |
---|---|
class |
SimpleCondition<T>
A user-defined condition that decides if an element should be accepted in the pattern or not.
|
class |
SubtypeCondition<T>
A
condition which filters elements of the given type. |
Modifier and Type | Class and Description |
---|---|
static class |
PageRank.EpsilonFilter
Filter that filters vertices where the rank difference is below a threshold.
|
Modifier and Type | Class and Description |
---|---|
static class |
EmptyFieldsCountAccumulator.EmptyFieldFilter
This function filters all incoming tuples that have one or more empty fields.
|
static class |
WebLogAnalysis.FilterByRank
MapFunction that filters for records where the rank exceeds a certain threshold.
|
static class |
WebLogAnalysis.FilterDocByKeyWords
MapFunction that filters for documents that contain a certain set of keywords.
|
static class |
WebLogAnalysis.FilterVisitsByDate
MapFunction that filters for records of the visits relation where the year (from the date
string) is equal to a certain value.
|
Modifier and Type | Method and Description |
---|---|
Graph<K,VV,EV> |
Graph.filterOnEdges(FilterFunction<Edge<K,EV>> edgeFilter)
Apply a filtering function to the graph and return a sub-graph that satisfies the predicates
only for the edges.
|
Graph<K,VV,EV> |
Graph.filterOnVertices(FilterFunction<Vertex<K,VV>> vertexFilter)
Apply a filtering function to the graph and return a sub-graph that satisfies the predicates
only for the vertices.
|
Graph<K,VV,EV> |
Graph.subgraph(FilterFunction<Vertex<K,VV>> vertexFilter,
FilterFunction<Edge<K,EV>> edgeFilter)
Apply filtering functions to the graph and return a sub-graph that satisfies the predicates
for both vertices and edges.
|
Graph<K,VV,EV> |
Graph.subgraph(FilterFunction<Vertex<K,VV>> vertexFilter,
FilterFunction<Edge<K,EV>> edgeFilter)
Apply filtering functions to the graph and return a sub-graph that satisfies the predicates
for both vertices and edges.
|
Modifier and Type | Method and Description |
---|---|
SingleOutputStreamOperator<T> |
DataStream.filter(FilterFunction<T> filter)
Applies a Filter transformation on a
DataStream . |
Constructor and Description |
---|
StreamFilter(FilterFunction<IN> filterFunction) |
Modifier and Type | Class and Description |
---|---|
class |
DropUpdateBeforeFunction
A function drops only rows with
RowKind.UPDATE_BEFORE changelog kind. |
Modifier and Type | Class and Description |
---|---|
class |
SinkNotNullEnforcer
Checks writing null values into NOT NULL columns.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.