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 |
AndFilterFunction<T>
Deprecated.
This is only used when migrating from an older Flink version.
Use the
AndCondition instead. |
class |
OrFilterFunction<T>
Deprecated.
This is only used when migrating from an older Flink version.
Use the
OrCondition instead. |
class |
SubtypeFilterFunction<T>
Deprecated.
This is only used when migrating from an older Flink version.
Use the
SubtypeCondition instead. |
Modifier and Type | Method and Description |
---|---|
FilterFunction<T> |
AndFilterFunction.getLeft()
Deprecated.
|
FilterFunction<T> |
OrFilterFunction.getLeft()
Deprecated.
|
FilterFunction<T> |
AndFilterFunction.getRight()
Deprecated.
|
FilterFunction<T> |
OrFilterFunction.getRight()
Deprecated.
|
Constructor and Description |
---|
AndFilterFunction(FilterFunction<T> left,
FilterFunction<T> right)
Deprecated.
|
AndFilterFunction(FilterFunction<T> left,
FilterFunction<T> right)
Deprecated.
|
OrFilterFunction(FilterFunction<T> left,
FilterFunction<T> right)
Deprecated.
|
OrFilterFunction(FilterFunction<T> left,
FilterFunction<T> right)
Deprecated.
|
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) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.