You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by lc...@apache.org on 2017/05/09 04:21:33 UTC
[13/13] beam git commit: [BEAM-2166] Use contextless encode/decode by
default.
[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 <lc...@google.com>
Authored: Mon May 8 21:21:09 2017 -0700
Committer: Luke Cwik <lc...@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(-)
----------------------------------------------------------------------