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/01/04 00:36:22 UTC
[6/6] beam git commit: [BEAM-1231] Use well known coder types in Java
[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(-)
----------------------------------------------------------------------