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 .The transformation calls a RichFilterFunction for each element of the DataSet
and retains only those element for which the function returns true. |
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 | Method and Description |
---|---|
static DataSet<T> |
CrossDataSet.filter(FilterFunction<T> filter) |
DataSet<T> |
DataSet.filter(FilterFunction<T> filter)
Creates a new DataSet that contains only the elements satisfying the given filter predicate.
|
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.
A filter function which combines two filter functions with a logical and. Thus, the filter function only returns true, iff both filters return true. |
class |
OrFilterFunction<T>
Deprecated.
This is only used when migrating from an older Flink version.
Use the
OrCondition instead.
A filter function which combines two filter functions with a logical or. Thus, the filter function only returns true, iff at least one of the filter functions holds true. |
class |
SubtypeFilterFunction<T>
Deprecated.
This is only used when migrating from an older Flink version.
Use the
SubtypeCondition instead.
A filter function which filters elements of the given type. A element if filtered out iff it is not assignable to the given subtype of T. |
Modifier and Type | Method and Description |
---|---|
FilterFunction<T> |
OrFilterFunction.getLeft()
Deprecated.
|
FilterFunction<T> |
AndFilterFunction.getLeft()
Deprecated.
|
FilterFunction<T> |
OrFilterFunction.getRight()
Deprecated.
|
FilterFunction<T> |
AndFilterFunction.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 | Class and Description |
---|---|
static class |
MusicProfiles.FilterSongNodes |
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 |
---|---|
static <T> Future<T> |
FutureUtils.retrySuccessful(Callable<Future<T>> operation,
FilterFunction<T> successPredicate,
scala.concurrent.duration.Deadline deadline,
Executor executor)
Retry the given operation the given number of times in case of a failure.
|
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 | Method and Description |
---|---|
DataStream<T> |
DataStream.filter(FilterFunction<T> filter)
Creates a new DataStream that contains only the elements satisfying the given filter predicate.
|
Modifier and Type | Class and Description |
---|---|
class |
LimitFilterFunction<T> |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.