You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2017/01/05 04:18:43 UTC
[3/3] beam git commit: This closes #1537: Add a new method on Coder
which returns a TypeDescriptor
This closes #1537: Add a new method on Coder which returns a TypeDescriptor
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/13767de8
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/13767de8
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/13767de8
Branch: refs/heads/master
Commit: 13767de888d3f0d31cc482ce1f037b9b8fafb66e
Parents: 1e2f90c 7b98fa0
Author: Kenneth Knowles <kl...@google.com>
Authored: Wed Jan 4 20:04:36 2017 -0800
Committer: Kenneth Knowles <kl...@google.com>
Committed: Wed Jan 4 20:04:36 2017 -0800
----------------------------------------------------------------------
.../streaming/io/UnboundedFlinkSink.java | 6 +++
.../beam/sdk/annotations/Experimental.java | 5 ++-
.../org/apache/beam/sdk/coders/AvroCoder.java | 7 ++++
.../beam/sdk/coders/BigEndianIntegerCoder.java | 7 ++++
.../beam/sdk/coders/BigEndianLongCoder.java | 7 ++++
.../apache/beam/sdk/coders/ByteArrayCoder.java | 7 ++++
.../org/apache/beam/sdk/coders/ByteCoder.java | 7 ++++
.../apache/beam/sdk/coders/ByteStringCoder.java | 8 ++++
.../java/org/apache/beam/sdk/coders/Coder.java | 7 ++++
.../apache/beam/sdk/coders/CollectionCoder.java | 8 ++++
.../apache/beam/sdk/coders/DelegateCoder.java | 29 +++++++++++++-
.../org/apache/beam/sdk/coders/DoubleCoder.java | 7 ++++
.../apache/beam/sdk/coders/DurationCoder.java | 8 ++++
.../apache/beam/sdk/coders/InstantCoder.java | 7 ++++
.../apache/beam/sdk/coders/IterableCoder.java | 8 ++++
.../org/apache/beam/sdk/coders/JAXBCoder.java | 8 ++++
.../org/apache/beam/sdk/coders/KvCoder.java | 9 +++++
.../org/apache/beam/sdk/coders/ListCoder.java | 7 ++++
.../org/apache/beam/sdk/coders/MapCoder.java | 9 +++++
.../apache/beam/sdk/coders/NullableCoder.java | 6 +++
.../beam/sdk/coders/SerializableCoder.java | 13 +++++--
.../org/apache/beam/sdk/coders/SetCoder.java | 8 ++++
.../apache/beam/sdk/coders/StandardCoder.java | 8 ++++
.../beam/sdk/coders/StringDelegateCoder.java | 16 ++++++--
.../apache/beam/sdk/coders/StringUtf8Coder.java | 7 ++++
.../beam/sdk/coders/TableRowJsonCoder.java | 7 ++++
.../beam/sdk/coders/TextualIntegerCoder.java | 8 ++++
.../org/apache/beam/sdk/coders/VarIntCoder.java | 10 ++++-
.../apache/beam/sdk/coders/VarLongCoder.java | 7 ++++
.../org/apache/beam/sdk/coders/VoidCoder.java | 7 ++++
.../org/apache/beam/sdk/testing/TestStream.java | 8 ++++
.../beam/sdk/values/TimestampedValue.java | 6 +++
.../apache/beam/sdk/coders/AvroCoderTest.java | 7 ++++
.../sdk/coders/BigEndianIntegerCoderTest.java | 9 +++++
.../beam/sdk/coders/BigEndianLongCoderTest.java | 9 +++++
.../beam/sdk/coders/ByteArrayCoderTest.java | 6 +++
.../apache/beam/sdk/coders/ByteCoderTest.java | 9 +++++
.../beam/sdk/coders/ByteStringCoderTest.java | 8 ++++
.../beam/sdk/coders/CoderRegistryTest.java | 6 +++
.../org/apache/beam/sdk/coders/CoderTest.java | 8 ++++
.../beam/sdk/coders/CollectionCoderTest.java | 10 +++++
.../beam/sdk/coders/DefaultCoderTest.java | 4 +-
.../beam/sdk/coders/DelegateCoderTest.java | 35 ++++++++++++++++-
.../apache/beam/sdk/coders/DoubleCoderTest.java | 9 +++++
.../beam/sdk/coders/DurationCoderTest.java | 10 +++++
.../beam/sdk/coders/InstantCoderTest.java | 9 +++++
.../beam/sdk/coders/IterableCoderTest.java | 9 +++++
.../apache/beam/sdk/coders/JAXBCoderTest.java | 10 +++++
.../org/apache/beam/sdk/coders/KvCoderTest.java | 10 +++++
.../apache/beam/sdk/coders/ListCoderTest.java | 8 ++++
.../apache/beam/sdk/coders/MapCoderTest.java | 10 +++++
.../beam/sdk/coders/NullableCoderTest.java | 6 +++
.../beam/sdk/coders/SerializableCoderTest.java | 9 +++++
.../apache/beam/sdk/coders/SetCoderTest.java | 10 +++++
.../beam/sdk/coders/StandardCoderTest.java | 40 ++++++++++++++++++++
.../sdk/coders/StringDelegateCoderTest.java | 11 ++++++
.../beam/sdk/coders/StringUtf8CoderTest.java | 9 +++++
.../beam/sdk/coders/TableRowJsonCoderTest.java | 9 +++++
.../sdk/coders/TextualIntegerCoderTest.java | 9 +++++
.../apache/beam/sdk/coders/VarIntCoderTest.java | 9 +++++
.../beam/sdk/coders/VarLongCoderTest.java | 9 +++++
.../apache/beam/sdk/coders/VoidCoderTest.java | 40 ++++++++++++++++++++
62 files changed, 605 insertions(+), 14 deletions(-)
----------------------------------------------------------------------