[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 <[email protected]> Authored: Sat May 6 20:34:00 2017 -0700 Committer: Luke Cwik <[email protected]> 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(-) ----------------------------------------------------------------------
