Package org.apache.flink.api.java

Class Utils.ChecksumHashCode

java.lang.Object

org.apache.flink.api.java.Utils.ChecksumHashCode

All Implemented Interfaces:

Serializable, Cloneable, org.apache.flink.api.common.accumulators.Accumulator<Utils.ChecksumHashCode,Utils.ChecksumHashCode>, org.apache.flink.api.common.accumulators.SimpleAccumulator<Utils.ChecksumHashCode>

Enclosing class:

Utils

public static class Utils.ChecksumHashCode
extends Object
implements org.apache.flink.api.common.accumulators.SimpleAccumulator<Utils.ChecksumHashCode>

Accumulator of Utils.ChecksumHashCode.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
ChecksumHashCode()
ChecksumHashCode(long count, long checksum)

Method Summary

Modifier and Type	Method	Description
void	add(Utils.ChecksumHashCode value)
Utils.ChecksumHashCode	clone()
boolean	equals(Object obj)
long	getChecksum()
long	getCount()
Utils.ChecksumHashCode	getLocalValue()
int	hashCode()
void	merge(org.apache.flink.api.common.accumulators.Accumulator<Utils.ChecksumHashCode,Utils.ChecksumHashCode> other)
void	resetLocal()
String	toString()

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

ChecksumHashCode

public ChecksumHashCode()

ChecksumHashCode

public ChecksumHashCode(long count,
                        long checksum)

Method Detail

getCount

public long getCount()

getChecksum

public long getChecksum()

add

public void add(Utils.ChecksumHashCode value)

Specified by:

add in interface org.apache.flink.api.common.accumulators.Accumulator<Utils.ChecksumHashCode,Utils.ChecksumHashCode>

getLocalValue

public Utils.ChecksumHashCode getLocalValue()

Specified by:

getLocalValue in interface org.apache.flink.api.common.accumulators.Accumulator<Utils.ChecksumHashCode,Utils.ChecksumHashCode>

resetLocal

public void resetLocal()

Specified by:

resetLocal in interface org.apache.flink.api.common.accumulators.Accumulator<Utils.ChecksumHashCode,Utils.ChecksumHashCode>

merge

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

Specified by:

merge in interface org.apache.flink.api.common.accumulators.Accumulator<Utils.ChecksumHashCode,Utils.ChecksumHashCode>

clone

public Utils.ChecksumHashCode clone()

Specified by:

clone in interface org.apache.flink.api.common.accumulators.Accumulator<Utils.ChecksumHashCode,Utils.ChecksumHashCode>

Overrides:

clone in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object