beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From lc...@apache.org
Subject [13/13] beam git commit: [BEAM-2166] Use contextless encode/decode by default.
Date Tue, 09 May 2017 04:21:33 GMT
[BEAM-2166] Use contextless encode/decode by default.

This closes #2933


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

Branch: refs/heads/master
Commit: 3a09ed5757c0e7a5f171350731403524c5d339fb
Parents: 23731fe fda3a43
Author: Luke Cwik <lcwik@google.com>
Authored: Mon May 8 21:21:09 2017 -0700
Committer: Luke Cwik <lcwik@google.com>
Committed: Mon May 8 21:21:09 2017 -0700

----------------------------------------------------------------------
 .../apex/translation/utils/ApexStreamTuple.java | 11 +++++
 .../UnboundedReadFromBoundedSource.java         | 12 ++---
 .../runners/core/construction/CodersTest.java   |  4 +-
 .../core/construction/PCollectionsTest.java     | 12 ++---
 .../core/ElementAndRestrictionCoder.java        | 12 ++---
 .../beam/runners/core/KeyedWorkItemCoder.java   | 18 +++----
 .../beam/runners/core/TimerInternals.java       | 22 ++++-----
 .../direct/CloningBundleFactoryTest.java        | 20 +++-----
 .../beam/runners/direct/DirectRunnerTest.java   |  4 +-
 .../UnboundedReadEvaluatorFactoryTest.java      |  5 +-
 .../translation/types/CoderTypeSerializer.java  |  4 +-
 .../streaming/SingletonKeyedWorkItemCoder.java  | 16 +++++-
 .../state/FlinkKeyGroupStateInternals.java      |  9 ++--
 runners/google-cloud-dataflow-java/pom.xml      |  2 +-
 .../runners/dataflow/BatchViewOverrides.java    | 16 +++---
 .../runners/dataflow/internal/IsmFormat.java    | 51 ++++++++++----------
 .../runners/dataflow/util/RandomAccessData.java | 11 +++++
 .../runners/dataflow/util/CloudObjectsTest.java |  8 +--
 .../spark/aggregators/NamedAggregators.java     |  4 +-
 .../beam/sdk/annotations/Experimental.java      |  3 ++
 .../org/apache/beam/sdk/coders/AvroCoder.java   |  4 +-
 .../apache/beam/sdk/coders/BigDecimalCoder.java | 15 +++++-
 .../beam/sdk/coders/BigEndianIntegerCoder.java  |  4 +-
 .../beam/sdk/coders/BigEndianLongCoder.java     |  4 +-
 .../apache/beam/sdk/coders/BigIntegerCoder.java | 11 +++++
 .../org/apache/beam/sdk/coders/BitSetCoder.java | 11 +++++
 .../apache/beam/sdk/coders/ByteArrayCoder.java  | 11 +++++
 .../org/apache/beam/sdk/coders/ByteCoder.java   |  4 +-
 .../java/org/apache/beam/sdk/coders/Coder.java  | 38 +++++----------
 .../org/apache/beam/sdk/coders/CustomCoder.java | 47 ------------------
 .../apache/beam/sdk/coders/DelegateCoder.java   | 11 +++++
 .../org/apache/beam/sdk/coders/DoubleCoder.java |  4 +-
 .../apache/beam/sdk/coders/DurationCoder.java   |  8 +--
 .../apache/beam/sdk/coders/InstantCoder.java    |  8 +--
 .../beam/sdk/coders/IterableLikeCoder.java      | 14 +++---
 .../org/apache/beam/sdk/coders/KvCoder.java     | 15 +++++-
 .../beam/sdk/coders/LengthPrefixCoder.java      |  4 +-
 .../org/apache/beam/sdk/coders/MapCoder.java    | 23 ++++++---
 .../apache/beam/sdk/coders/NullableCoder.java   | 11 +++++
 .../beam/sdk/coders/SerializableCoder.java      |  4 +-
 .../beam/sdk/coders/StringDelegateCoder.java    | 11 +++++
 .../apache/beam/sdk/coders/StringUtf8Coder.java | 11 +++++
 .../apache/beam/sdk/coders/StructuredCoder.java | 47 ------------------
 .../beam/sdk/coders/TextualIntegerCoder.java    | 11 +++++
 .../org/apache/beam/sdk/coders/VarIntCoder.java |  4 +-
 .../apache/beam/sdk/coders/VarLongCoder.java    |  4 +-
 .../org/apache/beam/sdk/coders/VoidCoder.java   |  4 +-
 .../org/apache/beam/sdk/io/FileBasedSink.java   | 15 +++---
 .../sdk/transforms/ApproximateQuantiles.java    | 44 ++++++++---------
 .../org/apache/beam/sdk/transforms/Combine.java | 23 +++++++++
 .../apache/beam/sdk/transforms/CombineFns.java  | 17 +++++--
 .../org/apache/beam/sdk/transforms/Count.java   |  4 +-
 .../org/apache/beam/sdk/transforms/Mean.java    | 12 ++---
 .../org/apache/beam/sdk/transforms/Top.java     |  8 +--
 .../beam/sdk/transforms/join/CoGbkResult.java   | 18 +++----
 .../beam/sdk/transforms/join/UnionCoder.java    | 11 +++++
 .../sdk/transforms/windowing/GlobalWindow.java  |  4 +-
 .../transforms/windowing/IntervalWindow.java    | 12 ++---
 .../beam/sdk/transforms/windowing/PaneInfo.java |  5 +-
 .../org/apache/beam/sdk/util/BitSetCoder.java   | 11 +++++
 .../org/apache/beam/sdk/util/WindowedValue.java | 37 ++++++++++----
 .../beam/sdk/values/TimestampedValue.java       | 13 +++--
 .../beam/sdk/values/ValueInSingleWindow.java    | 25 +++++++---
 .../beam/sdk/values/ValueWithRecordId.java      | 15 +++++-
 .../beam/sdk/coders/CoderRegistryTest.java      | 16 ++++--
 .../apache/beam/sdk/coders/CustomCoderTest.java |  4 +-
 .../beam/sdk/coders/NullableCoderTest.java      | 11 +++++
 .../beam/sdk/coders/SerializableCoderTest.java  | 28 +++++------
 .../beam/sdk/coders/StructuredCoderTest.java    | 12 ++---
 .../beam/sdk/testing/CoderPropertiesTest.java   | 36 +++++++-------
 .../apache/beam/sdk/testing/PAssertTest.java    |  4 +-
 .../sdk/testing/SerializableMatchersTest.java   |  5 +-
 .../beam/sdk/testing/WindowSupplierTest.java    |  4 +-
 .../beam/sdk/transforms/CombineFnsTest.java     | 11 +++++
 .../apache/beam/sdk/transforms/CombineTest.java | 25 +++++++---
 .../apache/beam/sdk/transforms/CreateTest.java  | 13 +++--
 .../beam/sdk/transforms/GroupByKeyTest.java     |  4 +-
 .../apache/beam/sdk/transforms/ParDoTest.java   | 12 ++---
 .../apache/beam/sdk/transforms/ViewTest.java    | 11 +++++
 .../transforms/reflect/DoFnInvokersTest.java    |  8 +--
 .../transforms/windowing/GlobalWindowTest.java  |  2 +-
 ...BufferedElementCountingOutputStreamTest.java |  5 +-
 .../apache/beam/sdk/util/CoderUtilsTest.java    |  4 +-
 .../beam/sdk/util/SerializableUtilsTest.java    |  4 +-
 .../extensions/protobuf/ByteStringCoder.java    | 11 +++++
 .../sdk/extensions/protobuf/ProtoCoder.java     | 11 +++++
 .../BeamFnDataBufferingOutboundObserver.java    |  3 +-
 .../harness/data/BeamFnDataInboundObserver.java |  3 +-
 ...BeamFnDataBufferingOutboundObserverTest.java |  3 +-
 .../data/BeamFnDataInboundObserverTest.java     |  3 +-
 .../sdk/io/gcp/bigquery/ShardedKeyCoder.java    | 11 +++--
 .../io/gcp/bigquery/TableDestinationCoder.java  | 12 ++---
 .../sdk/io/gcp/bigquery/TableRowInfoCoder.java  | 15 +++++-
 .../sdk/io/gcp/bigquery/TableRowJsonCoder.java  | 11 +++++
 .../io/gcp/bigquery/WriteBundlesToFiles.java    | 16 +++---
 .../pubsub/PubsubMessagePayloadOnlyCoder.java   | 11 +++++
 .../PubsubMessageWithAttributesCoder.java       | 15 +++++-
 .../sdk/io/gcp/pubsub/PubsubUnboundedSink.java  | 20 ++++----
 .../io/gcp/pubsub/PubsubUnboundedSource.java    | 13 +++--
 .../sdk/io/gcp/bigquery/BigQueryIOTest.java     | 11 +++++
 .../beam/sdk/io/hadoop/WritableCoder.java       |  4 +-
 .../beam/sdk/io/hbase/HBaseMutationCoder.java   |  6 +--
 .../beam/sdk/io/hbase/HBaseResultCoder.java     |  4 +-
 .../org/apache/beam/sdk/io/kafka/KafkaIO.java   |  4 +-
 .../beam/sdk/io/kafka/KafkaRecordCoder.java     | 11 +++++
 .../beam/sdk/io/kinesis/KinesisRecordCoder.java | 38 +++++++--------
 .../org/apache/beam/sdk/io/xml/JAXBCoder.java   | 25 ++++++----
 .../apache/beam/sdk/io/xml/JAXBCoderTest.java   | 21 +++++---
 108 files changed, 810 insertions(+), 552 deletions(-)
----------------------------------------------------------------------



Mime
View raw message