org.apache.flink.graph.asm.dataset

Class ChecksumHashCode<T>

java.lang.Object

org.apache.flink.graph.asm.dataset.DataSetAnalyticBase<T,ChecksumHashCode.Checksum>

org.apache.flink.graph.asm.dataset.ChecksumHashCode<T>

Type Parameters:

T - element type

All Implemented Interfaces:

DataSetAnalytic<T,ChecksumHashCode.Checksum>

public class ChecksumHashCode<T>
extends DataSetAnalyticBase<T,ChecksumHashCode.Checksum>

Convenience method to get the count (number of elements) of a DataSet as well as the checksum (sum over element hashes).

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ChecksumHashCode.Checksum Wraps checksum and count.

Field Summary

Fields inherited from class org.apache.flink.graph.asm.dataset.DataSetAnalyticBase

env

Constructor Summary

Constructors

Constructor and Description
ChecksumHashCode()

Method Summary

Modifier and Type	Method and Description
ChecksumHashCode.Checksum	getResult() This method must be called after the program has executed.
ChecksumHashCode<T>	run(org.apache.flink.api.java.DataSet<T> input) All DataSetAnalytic processing must be terminated by an OutputFormat and obtained via accumulators rather than returned by a DataSet.

Methods inherited from class org.apache.flink.graph.asm.dataset.DataSetAnalyticBase

execute, execute

Methods inherited from class java.lang.Object

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

Constructor Detail

ChecksumHashCode

public ChecksumHashCode()

Method Detail

run

public ChecksumHashCode<T> run(org.apache.flink.api.java.DataSet<T> input)
                        throws Exception

Description copied from interface: DataSetAnalytic

All DataSetAnalytic processing must be terminated by an OutputFormat and obtained via accumulators rather than returned by a DataSet.

Specified by:

run in interface DataSetAnalytic<T,ChecksumHashCode.Checksum>

Overrides:

run in class DataSetAnalyticBase<T,ChecksumHashCode.Checksum>

Parameters:

input - input dataset

Returns:

this

Throws:

Exception

getResult

public ChecksumHashCode.Checksum getResult()

Description copied from interface: DataSetAnalytic

This method must be called after the program has executed. 1) "run" analytics and algorithms 2) call ExecutionEnvironment.execute() 3) get analytic results

Returns:

the result