beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From lc...@apache.org
Subject [4/4] beam git commit: [BEAM-2174] Update CoderRegistry to allow creating coders through CoderFactory for a wider range of types
Date Fri, 05 May 2017 21:45:16 GMT
[BEAM-2174] Update CoderRegistry to allow creating coders through CoderFactory for a wider
range of types

This closes #2910


Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/947fa68a
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/947fa68a
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/947fa68a

Branch: refs/heads/master
Commit: 947fa68a53068a2eb0ce9955685f7a46cc543192
Parents: 6505988 f8e2cf8
Author: Luke Cwik <lcwik@google.com>
Authored: Fri May 5 14:45:03 2017 -0700
Committer: Luke Cwik <lcwik@google.com>
Committed: Fri May 5 14:45:03 2017 -0700

----------------------------------------------------------------------
 .../apache/beam/examples/complete/TfIdf.java    |   2 +-
 .../beam/examples/complete/TfIdfTest.java       |   2 +-
 .../beam/runners/core/SplittableParDo.java      |   4 +-
 .../CopyOnAccessInMemoryStateInternalsTest.java |   2 +-
 .../beam/runners/direct/DirectRunnerTest.java   |  10 -
 .../org/apache/beam/sdk/coders/AtomicCoder.java |  14 -
 .../org/apache/beam/sdk/coders/AvroCoder.java   |  42 +-
 .../apache/beam/sdk/coders/ByteArrayCoder.java  |   8 -
 .../sdk/coders/CannotProvideCoderException.java |   2 +-
 .../java/org/apache/beam/sdk/coders/Coder.java  |   4 +-
 .../apache/beam/sdk/coders/CoderFactories.java  | 292 ---------
 .../apache/beam/sdk/coders/CoderFactory.java    |  44 --
 .../apache/beam/sdk/coders/CoderProvider.java   |  19 +-
 .../beam/sdk/coders/CoderProviderRegistrar.java |  42 ++
 .../apache/beam/sdk/coders/CoderProviders.java  | 240 +++----
 .../apache/beam/sdk/coders/CoderRegistrar.java  |  45 --
 .../apache/beam/sdk/coders/CoderRegistry.java   | 618 +++++++------------
 .../apache/beam/sdk/coders/CollectionCoder.java |   9 -
 .../org/apache/beam/sdk/coders/CustomCoder.java |   8 -
 .../apache/beam/sdk/coders/DefaultCoder.java    | 119 +++-
 .../apache/beam/sdk/coders/IterableCoder.java   |   9 -
 .../beam/sdk/coders/IterableLikeCoder.java      |  12 -
 .../org/apache/beam/sdk/coders/KvCoder.java     |   7 -
 .../org/apache/beam/sdk/coders/ListCoder.java   |   8 -
 .../org/apache/beam/sdk/coders/MapCoder.java    |  12 -
 .../beam/sdk/coders/SerializableCoder.java      |  57 +-
 .../org/apache/beam/sdk/coders/SetCoder.java    |   9 -
 .../apache/beam/sdk/coders/VarLongCoder.java    |   7 -
 .../beam/sdk/transforms/CombineFnBase.java      |   4 +-
 .../apache/beam/sdk/transforms/CombineFns.java  |   4 +-
 .../org/apache/beam/sdk/transforms/Create.java  |  76 ++-
 .../apache/beam/sdk/transforms/PTransform.java  |   4 +-
 .../org/apache/beam/sdk/transforms/ParDo.java   |   8 +-
 .../apache/beam/sdk/transforms/WithKeys.java    |   4 +-
 .../sdk/transforms/windowing/GlobalWindow.java  |   6 -
 .../transforms/windowing/IntervalWindow.java    |   7 -
 .../org/apache/beam/sdk/values/PCollection.java |   2 +-
 .../beam/sdk/values/TimestampedValue.java       |   4 -
 .../beam/sdk/coders/CoderFactoriesTest.java     | 100 ---
 .../beam/sdk/coders/CoderProvidersTest.java     |  82 ++-
 .../beam/sdk/coders/CoderRegistryTest.java      | 167 ++---
 .../beam/sdk/coders/DefaultCoderTest.java       |  65 +-
 .../beam/sdk/coders/IterableCoderTest.java      |  17 -
 .../apache/beam/sdk/coders/ListCoderTest.java   |  17 -
 .../apache/beam/sdk/coders/MapCoderTest.java    |  20 -
 .../beam/sdk/coders/SerializableCoderTest.java  |  11 +
 .../beam/sdk/transforms/CombineFnsTest.java     |  10 +-
 .../apache/beam/sdk/transforms/CreateTest.java  |   6 +-
 .../sdk/transforms/FlatMapElementsTest.java     |   4 +-
 .../beam/sdk/transforms/GroupByKeyTest.java     |   4 +-
 .../beam/sdk/transforms/MapElementsTest.java    |   4 +-
 .../apache/beam/sdk/transforms/ParDoTest.java   |  17 +-
 .../transforms/reflect/DoFnInvokersTest.java    |   4 +-
 .../apache/beam/sdk/values/TypedPValueTest.java |  28 +-
 .../sdk/extensions/protobuf/ProtoCoder.java     |  72 ++-
 .../ProtobufCoderProviderRegistrar.java         |  41 ++
 .../protobuf/ProtobufCoderRegistrar.java        |  39 --
 .../sdk/extensions/protobuf/ProtoCoderTest.java |   7 +-
 .../BigQueryCoderProviderRegistrar.java         |  40 ++
 .../io/gcp/bigquery/BigQueryCoderRegistrar.java |  39 --
 .../io/gcp/bigquery/DynamicDestinations.java    |   2 +-
 .../pubsub/PubsubCoderProviderRegistrar.java    |  37 ++
 .../sdk/io/gcp/pubsub/PubsubCoderRegistrar.java |  35 --
 .../BigQueryCoderProviderRegistrarTest.java     |  40 ++
 .../bigquery/BigQueryCoderRegistrarTest.java    |  40 --
 sdks/java/io/hadoop-common/pom.xml              |   7 +
 .../beam/sdk/io/hadoop/WritableCoder.java       |  56 ++
 .../beam/sdk/io/hadoop/WritableCoderTest.java   |  10 +
 .../org/apache/beam/sdk/io/kafka/KafkaIO.java   |   2 +-
 .../beam/sdk/transforms/DistinctJava8Test.java  |   8 -
 .../beam/sdk/transforms/FilterJava8Test.java    |   2 +-
 .../beam/sdk/transforms/PartitionJava8Test.java |   2 +-
 .../beam/sdk/transforms/WithKeysJava8Test.java  |   9 -
 73 files changed, 1121 insertions(+), 1689 deletions(-)
----------------------------------------------------------------------



Mime
View raw message