beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From j...@apache.org
Subject [2/2] beam git commit: This closes #2450
Date Sat, 08 Apr 2017 01:26:32 GMT
This closes #2450


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

Branch: refs/heads/master
Commit: 7f55746ce3eb2a0b6ee2f6372d6f7127835cbb34
Parents: 1594849 8484ef9
Author: Eugene Kirpichov <kirpichov@google.com>
Authored: Fri Apr 7 18:26:15 2017 -0700
Committer: Eugene Kirpichov <kirpichov@google.com>
Committed: Fri Apr 7 18:26:15 2017 -0700

----------------------------------------------------------------------
 .../apache/beam/runners/apex/ApexRunner.java    |   2 -
 .../apex/translation/GroupByKeyTranslator.java  |   4 +-
 .../apex/translation/ParDoTranslator.java       |  15 +-
 .../apex/translation/TranslationContext.java    |  16 +-
 .../translation/WindowAssignTranslator.java     |  58 ++----
 .../operators/ApexGroupByKeyOperator.java       |  21 +--
 .../operators/ApexParDoOperator.java            | 187 +++++++++++++++----
 .../operators/ApexProcessFnOperator.java        | 184 ++++++++++++++++++
 .../translation/utils/ApexStateInternals.java   |  73 ++++++--
 .../translation/utils/StateInternalsProxy.java  |  67 +++++++
 .../translation/ApexGroupByKeyOperatorTest.java |   2 +-
 .../apex/translation/ParDoTranslatorTest.java   |   2 +-
 .../utils/ApexStateInternalsTest.java           |  25 ++-
 .../streaming/SingletonKeyedWorkItemCoder.java  |   2 +-
 14 files changed, 512 insertions(+), 146 deletions(-)
----------------------------------------------------------------------



Mime
View raw message