This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to tag nightly-master
in repository https://gitbox.apache.org/repos/asf/beam.git.
*** WARNING: tag nightly-master was modified! ***
from b8c001c (commit)
to 019db83 (commit)
from b8c001c Moving to 2.28.0-SNAPSHOT on master branch.
add 9c69229 [Beam-11002] Fixes BufferOverflowException in XMLReader
(#13513)
add db84863 Adding combiner packing optimization for Portable Runner
add 2202581 fix formatting
add fc84d02 Merge pull request #13573 from pabloem/cl151
add 4f6f923 [BEAM-10658] Update website to recommend the right version
add 0757359 Merge pull request #13576: [BEAM-10658] Update website to
recommend the right version
add f8d326e Rewrite container docs for custom containers (#13420)
add 77ff32c Cleanup directory with SVN repo for PMC members
add 1542971 Merge pull request #13580 from Cleanup directory with SVN
repo for PMC members
add 3663e03 [BEAM-11458] Upgrade SamzRunner to Samza 1.5 (#13550)
add 9732fa3 Add DataFrame Preview announcment blog post (#13561)
add 019db83 Dataframe docs (#13560)
No new revisions were added by this update.
Summary of changes:
.../src/main/scripts/preparation_before_release.sh | 2 +
runners/samza/build.gradle | 17 +-
.../beam/runners/samza/SamzaJobInvocation.java | 114 +++++
.../beam/runners/samza/SamzaJobServerDriver.java | 60 ++-
.../beam/runners/samza/SamzaPipelineOptions.java | 22 +-
.../samza/SamzaPipelineOptionsValidator.java | 38 +-
.../samza/SamzaPortablePipelineOptions.java | 13 +
.../runners/samza/SamzaRunnerOverrideConfigs.java | 15 +
.../samza/adapter/UnboundedSourceSystem.java | 39 +-
.../samza/container/BeamContainerRunner.java | 6 +-
.../samza/container/BeamJobCoordinatorRunner.java | 78 ++++
...inerCfgFactory.java => ContainerCfgLoader.java} | 18 +-
...ge-info.java => ContainerCfgLoaderFactory.java} | 14 +-
.../beam/runners/samza/runtime/BundleManager.java | 349 +++++++++++++++
.../apache/beam/runners/samza/runtime/DoFnOp.java | 277 +++++++-----
.../runners/samza/runtime/FutureCollector.java | 60 +++
.../beam/runners/samza/runtime/GroupByKeyOp.java | 11 +-
.../beam/runners/samza/runtime/KeyedTimerData.java | 1 +
.../beam/runners/samza/runtime/OpAdapter.java | 48 ++-
.../beam/runners/samza/runtime/OpEmitter.java | 5 +
.../samza/runtime/OutputManagerFactory.java | 5 +
.../samza/runtime/SamzaStoreStateInternals.java | 230 ++++++----
.../samza/runtime/SamzaTimerInternalsFactory.java | 217 ++++++++--
.../runners/samza/translation/ConfigBuilder.java | 77 ++--
.../runners/samza/translation/ConfigContext.java | 8 +
.../translation/FlattenPCollectionsTranslator.java | 2 +-
.../samza/translation/GroupByKeyTranslator.java | 24 +-
.../translation/ParDoBoundMultiTranslator.java | 56 ++-
.../samza/translation/SamzaPipelineTranslator.java | 21 +-
.../translation/SamzaTestStreamSystemFactory.java | 179 ++++++++
...nslator.java => SamzaTestStreamTranslator.java} | 70 +--
.../translation/SplittableParDoTranslators.java | 6 +-
.../samza/translation/TranslationContext.java | 59 ++-
.../samza/translation/WindowAssignTranslator.java | 4 +-
.../beam/runners/samza/util/FutureUtils.java | 50 +++
.../samza/SamzaPipelineOptionsValidatorTest.java | 60 +++
.../samza/adapter/UnboundedSourceSystemTest.java | 28 ++
.../runners/samza/runtime/BundleManagerTest.java | 474 +++++++++++++++++++++
.../samza/runtime/FutureCollectorImplTest.java | 92 ++++
.../runners/samza/runtime/KeyedTimerDataTest.java | 14 +-
.../runtime/SamzaStoreStateInternalsTest.java | 38 +-
.../runtime/SamzaTimerInternalsFactoryTest.java | 416 +++++++++++++++++-
.../samza/translation/ConfigGeneratorTest.java | 86 +++-
.../samza/translation/TranslationContextTest.java | 94 ++++
.../beam/runners/samza/util/FutureUtilsTest.java | 107 +++++
.../java/org/apache/beam/sdk/io/xml/XmlSource.java | 22 +-
.../org/apache/beam/sdk/io/xml/XmlSourceTest.java | 42 ++
.../runners/portability/portable_runner.py | 85 ++--
.../en/blog/dataframe-api-preview-available.md | 178 ++++++++
website/www/site/content/en/contribute/_index.md | 2 +-
.../en/documentation/dsls/dataframes/overview.md | 131 ++++++
.../documentation/io/built-in/google-bigquery.md | 4 +-
.../site/content/en/documentation/runners/samza.md | 5 +
.../en/documentation/runtime/environments.md | 305 ++++++++-----
website/www/site/data/authors.yml | 4 +
.../layouts/partials/section-menu/en/sdks.html | 17 +-
56 files changed, 3824 insertions(+), 575 deletions(-)
create mode 100644
runners/samza/src/main/java/org/apache/beam/runners/samza/SamzaJobInvocation.java
create mode 100644
runners/samza/src/main/java/org/apache/beam/runners/samza/container/BeamJobCoordinatorRunner.java
rename
runners/samza/src/main/java/org/apache/beam/runners/samza/container/{ContainerCfgFactory.java
=> ContainerCfgLoader.java} (79%)
copy
runners/samza/src/main/java/org/apache/beam/runners/samza/container/{package-info.java
=> ContainerCfgLoaderFactory.java} (68%)
create mode 100644
runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/BundleManager.java
create mode 100644
runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/FutureCollector.java
create mode 100644
runners/samza/src/main/java/org/apache/beam/runners/samza/translation/SamzaTestStreamSystemFactory.java
copy
runners/samza/src/main/java/org/apache/beam/runners/samza/translation/{ImpulseTranslator.java
=> SamzaTestStreamTranslator.java} (50%)
create mode 100644
runners/samza/src/main/java/org/apache/beam/runners/samza/util/FutureUtils.java
create mode 100644
runners/samza/src/test/java/org/apache/beam/runners/samza/SamzaPipelineOptionsValidatorTest.java
create mode 100644
runners/samza/src/test/java/org/apache/beam/runners/samza/runtime/BundleManagerTest.java
create mode 100644
runners/samza/src/test/java/org/apache/beam/runners/samza/runtime/FutureCollectorImplTest.java
create mode 100644
runners/samza/src/test/java/org/apache/beam/runners/samza/translation/TranslationContextTest.java
create mode 100644
runners/samza/src/test/java/org/apache/beam/runners/samza/util/FutureUtilsTest.java
create mode 100644
website/www/site/content/en/blog/dataframe-api-preview-available.md
create mode 100644
website/www/site/content/en/documentation/dsls/dataframes/overview.md
