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 |
---|---|
DataSet<T> |
DataSet.filter(FilterFunction<T> filter)
Creates a new DataSet that contains only the elements satisfying the given filter predicate.
|
Modifier and Type | Method and Description |
---|---|
FilterFunction<T> |
StateTransition.getCondition() |
Constructor and Description |
---|
StateTransition(StateTransitionAction action,
State<T> targetState,
FilterFunction<T> condition) |
Modifier and Type | Class and Description |
---|---|
class |
AndFilterFunction<T>
A filter function which combines two filter functions with a logical and.
|
class |
OrFilterFunction<T>
A filter function which combines two filter functions with a logical or.
|
class |
SubtypeFilterFunction<T>
A filter function which filters elements of the given type.
|
Modifier and Type | Method and Description |
---|---|
FilterFunction<F> |
Pattern.getFilterFunction() |
FilterFunction<T> |
OrFilterFunction.getLeft() |
FilterFunction<T> |
AndFilterFunction.getLeft() |
FilterFunction<T> |
OrFilterFunction.getRight() |
FilterFunction<T> |
AndFilterFunction.getRight() |
Modifier and Type | Method and Description |
---|---|
Pattern<T,F> |
Pattern.or(FilterFunction<F> orFilterFunction)
Specifies a filter condition which is ORed with an existing filter function.
|
Pattern<T,F> |
Pattern.where(FilterFunction<F> newFilterFunction)
Specifies a filter condition which has to be fulfilled by an event in order to be matched.
|
Constructor and Description |
---|
AndFilterFunction(FilterFunction<T> left,
FilterFunction<T> right) |
AndFilterFunction(FilterFunction<T> left,
FilterFunction<T> right) |
OrFilterFunction(FilterFunction<T> left,
FilterFunction<T> right) |
OrFilterFunction(FilterFunction<T> left,
FilterFunction<T> right) |
Modifier and Type | Method and Description |
---|---|
scala.Option<FilterFunction<F>> |
Pattern.getFilterFunction() |
Modifier and Type | Method and Description |
---|---|
Pattern<T,F> |
Pattern.or(FilterFunction<F> filter)
Specifies a filter condition which is ORed with an existing filter function.
|
Pattern<T,F> |
Pattern.where(FilterFunction<F> filter)
Specifies a filter condition which has to be fulfilled by an event in order to be matched.
|
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 |
---|---|
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–2017 The Apache Software Foundation. All rights reserved.