[
https://issues.apache.org/jira/browse/FLINK-2716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15093676#comment-15093676
]
ASF GitHub Bot commented on FLINK-2716:
---------------------------------------
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1462#discussion_r49435184
--- Diff:
flink-scala/src/main/scala/org/apache/flink/api/scala/utils/package.scala ---
@@ -103,6 +105,25 @@ package object utils {
: DataSet[T] = {
wrap(jutils.sampleWithSize(self.javaSet, withReplacement,
numSamples, seed))
}
+
+ //
--------------------------------------------------------------------------------------------
+ // Checksum
+ //
--------------------------------------------------------------------------------------------
+
+ /**
+ * Convenience method to get the count (number of elements) of a
DataSet
+ * as well as the checksum (sum over element hashes).
+ *
+ * @return A Checksum that represents the count and checksum of
elements in the data set.
+ *
+ * @see org.apache.flink.api.java.Utils.ChecksumHelper
--- End diff --
In Scaladocs one can link using
`[[org.apache.flink.api.java.Utils.ChecksumHelper]]`
> Checksum method for DataSet and Graph
> -------------------------------------
>
> Key: FLINK-2716
> URL: https://issues.apache.org/jira/browse/FLINK-2716
> Project: Flink
> Issue Type: Improvement
> Components: Gelly, Java API, Scala API
> Affects Versions: 0.10.0
> Reporter: Greg Hogan
> Assignee: Greg Hogan
> Priority: Minor
>
> {{DataSet.count()}}, {{Graph.numberOfVertices()}}, and
> {{Graph.numberOfEdges()}} provide measures of the number of distributed data
> elements. New {{DataSet.checksum()}} and {{Graph.checksum()}} methods will
> summarize the content of data elements and support algorithm validation,
> integration testing, and benchmarking.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
