This is an automated email from the ASF dual-hosted git repository. lcwik pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git
commit eabc640294fc265221824b011c18c79179e4d699 Author: ArnaudFnr <arnaudfournier...@gmail.com> AuthorDate: Wed Dec 27 01:13:17 2017 +0100 Small fix in SketchCoder --- .../org/apache/beam/sdk/extensions/sketching/SketchFrequencies.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/sdks/java/extensions/sketching/src/main/java/org/apache/beam/sdk/extensions/sketching/SketchFrequencies.java b/sdks/java/extensions/sketching/src/main/java/org/apache/beam/sdk/extensions/sketching/SketchFrequencies.java index 9872bcd..6508333 100644 --- a/sdks/java/extensions/sketching/src/main/java/org/apache/beam/sdk/extensions/sketching/SketchFrequencies.java +++ b/sdks/java/extensions/sketching/src/main/java/org/apache/beam/sdk/extensions/sketching/SketchFrequencies.java @@ -534,10 +534,10 @@ public final class SketchFrequencies { throw new CoderException("cannot encode a null Count-min Sketch"); } else { // 8L is for the sketch's size (long) - // 4L * 2 is for depth and width (ints) in Sketch<T> and in the Count-Min sketch + // 4L * 4 is for depth and width (ints) in Sketch<T> and in the Count-Min sketch // 8L * depth * (width + 1) is a factorization for the sizes of table (long[depth][width]) // and hashA (long[depth]) - return 8L + 4L * 4 + 8L * value.depth * (value.width + 1); + return 8L + 4L * 4 + 8L * value.getDepth() * (value.getWidth() + 1); } } } -- To stop receiving notification emails like this one, please contact lc...@apache.org.