Package org.apache.flink.examples.java.relational

Class EmptyFieldsCountAccumulator.EmptyFieldFilter

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

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>