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

Class EmptyFieldsCountAccumulator.VectorAccumulator

java.lang.Object

org.apache.flink.examples.java.relational.EmptyFieldsCountAccumulator.VectorAccumulator

All Implemented Interfaces:

Serializable, Cloneable, org.apache.flink.api.common.accumulators.Accumulator<Integer,ArrayList<Integer>>

Enclosing class:

EmptyFieldsCountAccumulator

public static class EmptyFieldsCountAccumulator.VectorAccumulator
extends Object
implements org.apache.flink.api.common.accumulators.Accumulator<Integer,ArrayList<Integer>>

This accumulator maintains a vector of counts. Calling add(Integer) increments the n-th vector component. The size of the vector is automatically managed.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
VectorAccumulator()
VectorAccumulator(ArrayList<Integer> resultVector)

Method Summary

Modifier and Type	Method	Description
void	add(Integer position)	Increases the result vector component at the specified position by 1.
org.apache.flink.api.common.accumulators.Accumulator<Integer,ArrayList<Integer>>	clone()
ArrayList<Integer>	getLocalValue()
void	merge(org.apache.flink.api.common.accumulators.Accumulator<Integer,ArrayList<Integer>> other)
void	resetLocal()
String	toString()

Methods inherited from class java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

VectorAccumulator

public VectorAccumulator()

VectorAccumulator

public VectorAccumulator(ArrayList<Integer> resultVector)

Method Detail

add

public void add(Integer position)

Increases the result vector component at the specified position by 1.

Specified by:

add in interface org.apache.flink.api.common.accumulators.Accumulator<Integer,ArrayList<Integer>>

getLocalValue

public ArrayList<Integer> getLocalValue()

Specified by:

getLocalValue in interface org.apache.flink.api.common.accumulators.Accumulator<Integer,ArrayList<Integer>>

resetLocal

public void resetLocal()

Specified by:

resetLocal in interface org.apache.flink.api.common.accumulators.Accumulator<Integer,ArrayList<Integer>>

merge

public void merge(org.apache.flink.api.common.accumulators.Accumulator<Integer,ArrayList<Integer>> other)

Specified by:

merge in interface org.apache.flink.api.common.accumulators.Accumulator<Integer,ArrayList<Integer>>

clone

public org.apache.flink.api.common.accumulators.Accumulator<Integer,ArrayList<Integer>> clone()

Specified by:

clone in interface org.apache.flink.api.common.accumulators.Accumulator<Integer,ArrayList<Integer>>

Overrides:

clone in class Object

toString

public String toString()

Overrides:

toString in class Object