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 <[email protected]> Authored: Wed Jan 4 20:04:36 2017 -0800 Committer: Kenneth Knowles <[email protected]> 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(-) ----------------------------------------------------------------------
