[BEAM-1231] Use well known coder types in Java This closes #1717
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/5c612272 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/5c612272 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/5c612272 Branch: refs/heads/master Commit: 5c612272d582421fbd540381c150e68205470f3b Parents: d86db15 8c69214 Author: Luke Cwik <lc...@google.com> Authored: Tue Jan 3 16:36:05 2017 -0800 Committer: Luke Cwik <lc...@google.com> Committed: Tue Jan 3 16:36:05 2017 -0800 ---------------------------------------------------------------------- .../runners/core/KeyedWorkItemCoderTest.java | 6 + .../UnboundedReadFromBoundedSourceTest.java | 7 + .../runners/dataflow/internal/IsmFormat.java | 14 +- .../beam/runners/dataflow/dataflow.properties | 4 +- .../runners/spark/coders/WritableCoder.java | 4 +- .../org/apache/beam/sdk/coders/AtomicCoder.java | 2 +- .../org/apache/beam/sdk/coders/AvroCoder.java | 4 +- .../apache/beam/sdk/coders/CollectionCoder.java | 4 +- .../org/apache/beam/sdk/coders/CustomCoder.java | 18 +-- .../apache/beam/sdk/coders/IterableCoder.java | 4 +- .../org/apache/beam/sdk/coders/JAXBCoder.java | 4 +- .../org/apache/beam/sdk/coders/KvCoder.java | 4 +- .../beam/sdk/coders/LengthPrefixCoder.java | 145 +++++++++++++++++++ .../beam/sdk/coders/SerializableCoder.java | 4 +- .../org/apache/beam/sdk/coders/SetCoder.java | 4 +- .../apache/beam/sdk/coders/StandardCoder.java | 31 +++- .../beam/sdk/coders/protobuf/ProtoCoder.java | 8 +- .../org/apache/beam/sdk/transforms/Combine.java | 11 +- .../beam/sdk/transforms/join/CoGbkResult.java | 13 +- .../sdk/transforms/windowing/GlobalWindow.java | 6 + .../org/apache/beam/sdk/util/CoderUtils.java | 28 ++-- .../org/apache/beam/sdk/util/WindowedValue.java | 12 +- .../beam/sdk/values/TimestampedValue.java | 4 +- .../beam/sdk/coders/CollectionCoderTest.java | 6 + .../beam/sdk/coders/IterableCoderTest.java | 18 ++- .../org/apache/beam/sdk/coders/KvCoderTest.java | 19 +++ .../beam/sdk/coders/LengthPrefixCoderTest.java | 129 +++++++++++++++++ .../apache/beam/sdk/coders/ListCoderTest.java | 8 +- .../apache/beam/sdk/coders/MapCoderTest.java | 9 +- .../beam/sdk/coders/NullableCoderTest.java | 6 + .../apache/beam/sdk/coders/SetCoderTest.java | 6 + .../apache/beam/sdk/testing/TestStreamTest.java | 5 + .../testing/ValueInSingleWindowCoderTest.java | 7 + .../apache/beam/sdk/transforms/CombineTest.java | 70 --------- .../transforms/join/CoGbkResultCoderTest.java | 10 +- .../sdk/transforms/join/UnionCoderTest.java | 24 +-- .../transforms/windowing/GlobalWindowTest.java | 64 ++++++++ .../beam/sdk/util/SerializableUtilsTest.java | 4 +- .../beam/sdk/util/TimerInternalsTest.java | 5 + .../beam/sdk/util/ValueWithRecordIdTest.java | 34 +++++ .../apache/beam/sdk/util/WindowedValueTest.java | 23 +++ .../beam/sdk/values/TimestampedValueTest.java | 19 ++- .../beam/sdk/io/gcp/bigquery/BigQueryIO.java | 7 +- .../sdk/io/gcp/bigquery/BigQueryIOTest.java | 6 + .../beam/sdk/io/hdfs/AvroWrapperCoder.java | 4 +- .../apache/beam/sdk/io/hdfs/WritableCoder.java | 4 +- .../beam/sdk/io/hdfs/AvroWrapperCoderTest.java | 1 - .../beam/sdk/io/kafka/KafkaRecordCoderTest.java | 34 +++++ 48 files changed, 677 insertions(+), 186 deletions(-) ----------------------------------------------------------------------