This is an automated email from the ASF dual-hosted git repository.
kenn pushed a commit to branch samza-runner
in repository https://gitbox.apache.org/repos/asf/beam.git
commit 7be38fe0489039c2cc04b58a2b44f897298470db
Merge: 349419a f20fc9a
Author: Kenn Knowles <k...@kennknowles.com>
AuthorDate: Mon Jun 18 08:25:42 2018 -0700
Merge pull request #5517: [BEAM-3079] Update samza-runner with more
features and improvements
examples/java/pom.xml | 12 +
pom.xml | 6 +
runners/samza/.gitignore | 1 -
runners/samza/pom.xml | 60 ++-
.../beam/runners/samza/SamzaPipelineOptions.java | 24 +-
.../beam/runners/samza/SamzaPipelineResult.java | 129 +++---
.../org/apache/beam/runners/samza/SamzaRunner.java | 59 +--
.../apache/beam/runners/samza/TestSamzaRunner.java | 32 +-
.../runners/samza/adapter/BoundedSourceSystem.java | 2 -
.../samza/adapter/UnboundedSourceSystem.java | 30 +-
.../samza/metrics/DoFnRunnerWithMetrics.java | 5 +
.../samza/metrics/FnWithMetricsWrapper.java | 1 -
.../samza/metrics/SamzaMetricsContainer.java | 15 +-
.../apache/beam/runners/samza/runtime/DoFnOp.java | 174 +++++----
.../runtime/DoFnRunnerWithKeyedInternals.java | 216 +++++++++++
.../beam/runners/samza/runtime/GroupByKeyOp.java | 98 +++--
.../beam/runners/samza/runtime/KeyedInternals.java | 168 ++++++++
.../runners/samza/runtime/KvToKeyedWorkItemOp.java | 2 +-
.../org/apache/beam/runners/samza/runtime/Op.java | 16 +-
.../beam/runners/samza/runtime/OpAdapter.java | 57 ++-
.../beam/runners/samza/runtime/OpMessage.java | 20 +-
.../samza/runtime/SamzaStoreStateInternals.java | 432 +++++++++++++++++++--
.../samza/runtime/SamzaTimerInternalsFactory.java | 101 +++--
.../beam/runners/samza/runtime/WindowAssignOp.java | 2 +-
.../beam/runners/samza/state/SamzaMapState.java | 44 +++
.../beam/runners/samza/state/SamzaSetState.java | 43 ++
.../package-info.java} | 19 +-
.../runners/samza/translation/ConfigBuilder.java | 124 ++++--
.../translation/FlattenPCollectionsTranslator.java | 3 +-
.../samza/translation/GroupByKeyTranslator.java | 119 +++---
.../translation/ParDoBoundMultiTranslator.java | 65 +++-
...nboundedTranslator.java => ReadTranslator.java} | 9 +-
.../samza/translation/SamzaPipelineTranslator.java | 100 +++--
.../samza/translation/SamzaPublishView.java | 14 +
.../translation/SamzaPublishViewTranslator.java | 24 +-
.../samza/translation/SamzaTransformOverrides.java | 4 +-
.../samza/translation/TranslationContext.java | 4 +
.../beam/runners/samza/util/SamzaCoders.java | 77 ++++
.../samza/src/main/resources/samza-conf.properties | 9 +-
.../samza/adapter/BoundedSourceSystemTest.java | 1 -
.../runners/samza/adapter/TestBoundedSource.java | 1 -
.../runners/samza/adapter/TestSourceHelpers.java | 1 +
.../samza/adapter/UnboundedSourceSystemTest.java | 1 -
.../runtime/SamzaStoreStateInternalsTest.java | 294 ++++++++++++++
.../samza/src/test/resources/log4j-test.properties | 2 +-
45 files changed, 2041 insertions(+), 579 deletions(-)
--
To stop receiving notification emails like this one, please contact
k...@apache.org.
