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 | Method and Description |
---|---|
static <T> SimpleCondition<T> |
SimpleCondition.of(FilterFunction<T> filters) |
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 |
---|---|
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. |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.