You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by lc...@apache.org on 2017/05/07 03:34:12 UTC

[3/3] beam git commit: [BEAM-2166] Remove context from size estimating operations.

[BEAM-2166] Remove context from size estimating operations.

This closes #2930


Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/dabad1ae
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/dabad1ae
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/dabad1ae

Branch: refs/heads/master
Commit: dabad1ae595f7081c74f775209037caaae558a0d
Parents: 019d300 96de8d7
Author: Luke Cwik <lc...@google.com>
Authored: Sat May 6 20:34:00 2017 -0700
Committer: Luke Cwik <lc...@google.com>
Committed: Sat May 6 20:34:00 2017 -0700

----------------------------------------------------------------------
 runners/google-cloud-dataflow-java/pom.xml      |  2 +-
 .../runners/dataflow/internal/IsmFormat.java    |  8 +--
 .../runners/dataflow/util/RandomAccessData.java | 11 ++---
 .../dataflow/util/RandomAccessDataTest.java     |  6 +--
 .../apache/beam/sdk/coders/BigDecimalCoder.java |  8 +--
 .../beam/sdk/coders/BigEndianIntegerCoder.java  |  4 +-
 .../beam/sdk/coders/BigEndianLongCoder.java     |  4 +-
 .../apache/beam/sdk/coders/BigIntegerCoder.java |  6 +--
 .../apache/beam/sdk/coders/ByteArrayCoder.java  | 10 ++--
 .../org/apache/beam/sdk/coders/ByteCoder.java   |  4 +-
 .../java/org/apache/beam/sdk/coders/Coder.java  | 52 ++++----------------
 .../org/apache/beam/sdk/coders/DoubleCoder.java |  4 +-
 .../apache/beam/sdk/coders/DurationCoder.java   |  8 +--
 .../apache/beam/sdk/coders/InstantCoder.java    |  8 +--
 .../beam/sdk/coders/IterableLikeCoder.java      |  9 ++--
 .../org/apache/beam/sdk/coders/KvCoder.java     | 12 ++---
 .../beam/sdk/coders/LengthPrefixCoder.java      | 11 ++---
 .../org/apache/beam/sdk/coders/MapCoder.java    | 10 ++--
 .../apache/beam/sdk/coders/NullableCoder.java   | 14 +++---
 .../beam/sdk/coders/StringDelegateCoder.java    |  1 -
 .../apache/beam/sdk/coders/StringUtf8Coder.java | 16 ++----
 .../beam/sdk/coders/TextualIntegerCoder.java    |  4 +-
 .../org/apache/beam/sdk/coders/VarIntCoder.java |  4 +-
 .../apache/beam/sdk/coders/VarLongCoder.java    |  4 +-
 .../org/apache/beam/sdk/coders/VoidCoder.java   |  4 +-
 .../beam/sdk/testing/CoderProperties.java       |  6 ++-
 .../sdk/transforms/ApproximateQuantiles.java    | 22 +++------
 .../org/apache/beam/sdk/transforms/Count.java   |  4 +-
 .../org/apache/beam/sdk/transforms/Top.java     |  9 ++--
 .../beam/sdk/transforms/join/UnionCoder.java    |  8 +--
 .../org/apache/beam/sdk/util/BitSetCoder.java   |  1 -
 .../org/apache/beam/sdk/util/WindowedValue.java | 15 +++---
 .../beam/sdk/coders/BigDecimalCoderTest.java    |  5 +-
 .../beam/sdk/coders/BigIntegerCoderTest.java    |  5 +-
 .../beam/sdk/coders/CoderRegistryTest.java      |  4 +-
 .../beam/sdk/coders/LengthPrefixCoderTest.java  | 24 +++++----
 .../beam/sdk/coders/NullableCoderTest.java      | 18 +++----
 .../apache/beam/sdk/testing/PAssertTest.java    |  4 +-
 .../apache/beam/sdk/transforms/CombineTest.java |  8 +--
 .../apache/beam/sdk/transforms/ParDoTest.java   |  4 +-
 .../extensions/protobuf/ByteStringCoder.java    |  8 +--
 .../protobuf/ByteStringCoderTest.java           | 10 ++--
 .../sdk/io/gcp/bigquery/TableRowJsonCoder.java  |  4 +-
 .../beam/sdk/io/kafka/KafkaRecordCoder.java     |  4 +-
 .../org/apache/beam/sdk/io/xml/JAXBCoder.java   | 40 ++++++++-------
 45 files changed, 178 insertions(+), 249 deletions(-)
----------------------------------------------------------------------