beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From k...@apache.org
Subject [3/3] beam git commit: This closes #1537: Add a new method on Coder which returns a TypeDescriptor
Date Thu, 05 Jan 2017 04:18:43 GMT
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 <klk@google.com>
Authored: Wed Jan 4 20:04:36 2017 -0800
Committer: Kenneth Knowles <klk@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(-)
----------------------------------------------------------------------



Mime
View raw message