[BEAM-2166] Use contextless encode/decode by default. This closes #2933
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/3a09ed57 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/3a09ed57 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/3a09ed57 Branch: refs/heads/master Commit: 3a09ed5757c0e7a5f171350731403524c5d339fb Parents: 23731fe fda3a43 Author: Luke Cwik <[email protected]> Authored: Mon May 8 21:21:09 2017 -0700 Committer: Luke Cwik <[email protected]> Committed: Mon May 8 21:21:09 2017 -0700 ---------------------------------------------------------------------- .../apex/translation/utils/ApexStreamTuple.java | 11 +++++ .../UnboundedReadFromBoundedSource.java | 12 ++--- .../runners/core/construction/CodersTest.java | 4 +- .../core/construction/PCollectionsTest.java | 12 ++--- .../core/ElementAndRestrictionCoder.java | 12 ++--- .../beam/runners/core/KeyedWorkItemCoder.java | 18 +++---- .../beam/runners/core/TimerInternals.java | 22 ++++----- .../direct/CloningBundleFactoryTest.java | 20 +++----- .../beam/runners/direct/DirectRunnerTest.java | 4 +- .../UnboundedReadEvaluatorFactoryTest.java | 5 +- .../translation/types/CoderTypeSerializer.java | 4 +- .../streaming/SingletonKeyedWorkItemCoder.java | 16 +++++- .../state/FlinkKeyGroupStateInternals.java | 9 ++-- runners/google-cloud-dataflow-java/pom.xml | 2 +- .../runners/dataflow/BatchViewOverrides.java | 16 +++--- .../runners/dataflow/internal/IsmFormat.java | 51 ++++++++++---------- .../runners/dataflow/util/RandomAccessData.java | 11 +++++ .../runners/dataflow/util/CloudObjectsTest.java | 8 +-- .../spark/aggregators/NamedAggregators.java | 4 +- .../beam/sdk/annotations/Experimental.java | 3 ++ .../org/apache/beam/sdk/coders/AvroCoder.java | 4 +- .../apache/beam/sdk/coders/BigDecimalCoder.java | 15 +++++- .../beam/sdk/coders/BigEndianIntegerCoder.java | 4 +- .../beam/sdk/coders/BigEndianLongCoder.java | 4 +- .../apache/beam/sdk/coders/BigIntegerCoder.java | 11 +++++ .../org/apache/beam/sdk/coders/BitSetCoder.java | 11 +++++ .../apache/beam/sdk/coders/ByteArrayCoder.java | 11 +++++ .../org/apache/beam/sdk/coders/ByteCoder.java | 4 +- .../java/org/apache/beam/sdk/coders/Coder.java | 38 +++++---------- .../org/apache/beam/sdk/coders/CustomCoder.java | 47 ------------------ .../apache/beam/sdk/coders/DelegateCoder.java | 11 +++++ .../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 | 14 +++--- .../org/apache/beam/sdk/coders/KvCoder.java | 15 +++++- .../beam/sdk/coders/LengthPrefixCoder.java | 4 +- .../org/apache/beam/sdk/coders/MapCoder.java | 23 ++++++--- .../apache/beam/sdk/coders/NullableCoder.java | 11 +++++ .../beam/sdk/coders/SerializableCoder.java | 4 +- .../beam/sdk/coders/StringDelegateCoder.java | 11 +++++ .../apache/beam/sdk/coders/StringUtf8Coder.java | 11 +++++ .../apache/beam/sdk/coders/StructuredCoder.java | 47 ------------------ .../beam/sdk/coders/TextualIntegerCoder.java | 11 +++++ .../org/apache/beam/sdk/coders/VarIntCoder.java | 4 +- .../apache/beam/sdk/coders/VarLongCoder.java | 4 +- .../org/apache/beam/sdk/coders/VoidCoder.java | 4 +- .../org/apache/beam/sdk/io/FileBasedSink.java | 15 +++--- .../sdk/transforms/ApproximateQuantiles.java | 44 ++++++++--------- .../org/apache/beam/sdk/transforms/Combine.java | 23 +++++++++ .../apache/beam/sdk/transforms/CombineFns.java | 17 +++++-- .../org/apache/beam/sdk/transforms/Count.java | 4 +- .../org/apache/beam/sdk/transforms/Mean.java | 12 ++--- .../org/apache/beam/sdk/transforms/Top.java | 8 +-- .../beam/sdk/transforms/join/CoGbkResult.java | 18 +++---- .../beam/sdk/transforms/join/UnionCoder.java | 11 +++++ .../sdk/transforms/windowing/GlobalWindow.java | 4 +- .../transforms/windowing/IntervalWindow.java | 12 ++--- .../beam/sdk/transforms/windowing/PaneInfo.java | 5 +- .../org/apache/beam/sdk/util/BitSetCoder.java | 11 +++++ .../org/apache/beam/sdk/util/WindowedValue.java | 37 ++++++++++---- .../beam/sdk/values/TimestampedValue.java | 13 +++-- .../beam/sdk/values/ValueInSingleWindow.java | 25 +++++++--- .../beam/sdk/values/ValueWithRecordId.java | 15 +++++- .../beam/sdk/coders/CoderRegistryTest.java | 16 ++++-- .../apache/beam/sdk/coders/CustomCoderTest.java | 4 +- .../beam/sdk/coders/NullableCoderTest.java | 11 +++++ .../beam/sdk/coders/SerializableCoderTest.java | 28 +++++------ .../beam/sdk/coders/StructuredCoderTest.java | 12 ++--- .../beam/sdk/testing/CoderPropertiesTest.java | 36 +++++++------- .../apache/beam/sdk/testing/PAssertTest.java | 4 +- .../sdk/testing/SerializableMatchersTest.java | 5 +- .../beam/sdk/testing/WindowSupplierTest.java | 4 +- .../beam/sdk/transforms/CombineFnsTest.java | 11 +++++ .../apache/beam/sdk/transforms/CombineTest.java | 25 +++++++--- .../apache/beam/sdk/transforms/CreateTest.java | 13 +++-- .../beam/sdk/transforms/GroupByKeyTest.java | 4 +- .../apache/beam/sdk/transforms/ParDoTest.java | 12 ++--- .../apache/beam/sdk/transforms/ViewTest.java | 11 +++++ .../transforms/reflect/DoFnInvokersTest.java | 8 +-- .../transforms/windowing/GlobalWindowTest.java | 2 +- ...BufferedElementCountingOutputStreamTest.java | 5 +- .../apache/beam/sdk/util/CoderUtilsTest.java | 4 +- .../beam/sdk/util/SerializableUtilsTest.java | 4 +- .../extensions/protobuf/ByteStringCoder.java | 11 +++++ .../sdk/extensions/protobuf/ProtoCoder.java | 11 +++++ .../BeamFnDataBufferingOutboundObserver.java | 3 +- .../harness/data/BeamFnDataInboundObserver.java | 3 +- ...BeamFnDataBufferingOutboundObserverTest.java | 3 +- .../data/BeamFnDataInboundObserverTest.java | 3 +- .../sdk/io/gcp/bigquery/ShardedKeyCoder.java | 11 +++-- .../io/gcp/bigquery/TableDestinationCoder.java | 12 ++--- .../sdk/io/gcp/bigquery/TableRowInfoCoder.java | 15 +++++- .../sdk/io/gcp/bigquery/TableRowJsonCoder.java | 11 +++++ .../io/gcp/bigquery/WriteBundlesToFiles.java | 16 +++--- .../pubsub/PubsubMessagePayloadOnlyCoder.java | 11 +++++ .../PubsubMessageWithAttributesCoder.java | 15 +++++- .../sdk/io/gcp/pubsub/PubsubUnboundedSink.java | 20 ++++---- .../io/gcp/pubsub/PubsubUnboundedSource.java | 13 +++-- .../sdk/io/gcp/bigquery/BigQueryIOTest.java | 11 +++++ .../beam/sdk/io/hadoop/WritableCoder.java | 4 +- .../beam/sdk/io/hbase/HBaseMutationCoder.java | 6 +-- .../beam/sdk/io/hbase/HBaseResultCoder.java | 4 +- .../org/apache/beam/sdk/io/kafka/KafkaIO.java | 4 +- .../beam/sdk/io/kafka/KafkaRecordCoder.java | 11 +++++ .../beam/sdk/io/kinesis/KinesisRecordCoder.java | 38 +++++++-------- .../org/apache/beam/sdk/io/xml/JAXBCoder.java | 25 ++++++---- .../apache/beam/sdk/io/xml/JAXBCoderTest.java | 21 +++++--- 108 files changed, 810 insertions(+), 552 deletions(-) ----------------------------------------------------------------------
