beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dhalp...@apache.org
Subject [2/2] beam git commit: This closes #1680
Date Wed, 28 Dec 2016 23:31:20 GMT
This closes #1680


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

Branch: refs/heads/master
Commit: 84134bcabaada697a22728f56f030a0351394e45
Parents: b6944cd 496ebbe
Author: Dan Halperin <dhalperi@google.com>
Authored: Wed Dec 28 15:31:06 2016 -0800
Committer: Dan Halperin <dhalperi@google.com>
Committed: Wed Dec 28 15:31:06 2016 -0800

----------------------------------------------------------------------
 .../beam/runners/core/KeyedWorkItemCoder.java   |  4 +-
 .../core/UnboundedReadFromBoundedSource.java    | 10 ++--
 .../streaming/SingletonKeyedWorkItemCoder.java  | 10 ++--
 .../beam/runners/dataflow/DataflowRunner.java   |  4 +-
 .../DataflowUnboundedReadFromBoundedSource.java | 10 ++--
 .../runners/dataflow/internal/IsmFormat.java    |  6 +--
 .../apache/beam/sdk/coders/BigDecimalCoder.java |  6 +--
 .../org/apache/beam/sdk/coders/KvCoder.java     | 22 +++-----
 .../org/apache/beam/sdk/coders/MapCoder.java    | 53 +++++++++++++++-----
 .../apache/beam/sdk/io/PubsubUnboundedSink.java | 12 ++---
 .../beam/sdk/testing/ValueInSingleWindow.java   |  6 +--
 .../apache/beam/sdk/transforms/CombineFns.java  | 14 +++++-
 .../org/apache/beam/sdk/transforms/Mean.java    | 10 ++--
 .../beam/sdk/transforms/join/CoGbkResult.java   | 22 ++++++--
 .../transforms/windowing/IntervalWindow.java    |  4 +-
 .../apache/beam/sdk/util/TimerInternals.java    |  4 +-
 .../org/apache/beam/sdk/util/WindowedValue.java | 11 ++--
 .../beam/sdk/coders/BigDecimalCoderTest.java    | 46 ++++++++---------
 .../apache/beam/sdk/coders/JAXBCoderTest.java   | 16 +++---
 .../apache/beam/sdk/coders/MapCoderTest.java    |  2 +-
 .../apache/beam/sdk/transforms/CombineTest.java |  6 +--
 .../beam/sdk/io/gcp/bigquery/BigQueryIO.java    |  4 +-
 .../beam/sdk/io/kafka/KafkaRecordCoder.java     |  4 +-
 .../beam/sdk/io/kinesis/KinesisRecordCoder.java |  4 +-
 24 files changed, 164 insertions(+), 126 deletions(-)
----------------------------------------------------------------------



Mime
View raw message