EmptyFieldsCountAccumulator.EmptyFieldFilter (Flink : Examples : Batch 1.20.0-cp1 API)

java.lang.Object
- org.apache.flink.api.common.functions.AbstractRichFunction
- - org.apache.flink.api.common.functions.RichFilterFunction<EmptyFieldsCountAccumulator.StringTriple>
  - - org.apache.flink.examples.java.relational.EmptyFieldsCountAccumulator.EmptyFieldFilter

All Implemented Interfaces:

Serializable, org.apache.flink.api.common.functions.FilterFunction<EmptyFieldsCountAccumulator.StringTriple>, org.apache.flink.api.common.functions.Function, org.apache.flink.api.common.functions.RichFunction

Enclosing class:

EmptyFieldsCountAccumulator
```
public static final class EmptyFieldsCountAccumulator.EmptyFieldFilter
extends org.apache.flink.api.common.functions.RichFilterFunction<EmptyFieldsCountAccumulator.StringTriple>
```
This function filters all incoming tuples that have one or more empty fields. In doing so, it also counts the number of empty fields per attribute with an accumulator (registered under EmptyFieldsCountAccumulator.EMPTY_FIELD_ACCUMULATOR).

See Also:

Serialized Form

Constructor Summary

Constructors
Constructor Description

EmptyFieldFilter()

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`boolean`	`filter(EmptyFieldsCountAccumulator.StringTriple t)`
`void`	`open(org.apache.flink.api.common.functions.OpenContext openContext)`

Methods inherited from class org.apache.flink.api.common.functions.AbstractRichFunction
close, getIterationRuntimeContext, getRuntimeContext, open, setRuntimeContext

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - EmptyFieldFilter
```
public EmptyFieldFilter()
```
- Method Detail
  - open
```
public void open(org.apache.flink.api.common.functions.OpenContext openContext)
          throws Exception
```
    Throws:
    
    Exception
  - filter
```
public boolean filter(EmptyFieldsCountAccumulator.StringTriple t)
```
    Specified by:
    
    filter in interface org.apache.flink.api.common.functions.FilterFunction<EmptyFieldsCountAccumulator.StringTriple>
    
    Specified by:
    
    filter in class org.apache.flink.api.common.functions.RichFilterFunction<EmptyFieldsCountAccumulator.StringTriple>