[beam] annotated tag v2.36.0-RC2 updated (832a000 -> dd105dd)
This is an automated email from the ASF dual-hosted git repository. emilyye pushed a change to annotated tag v2.36.0-RC2 in repository https://gitbox.apache.org/repos/asf/beam.git. *** WARNING: tag v2.36.0-RC2 was modified! *** from 832a000 (commit) to dd105dd (tag) tagging 832a000b3d02eb6e6454cb8e97c0d24535f2e975 (commit) replaces jupyterlab-sidepanel-v2.0.0 by Emily Ye on Thu Feb 3 17:52:47 2022 + - Log - v2.36.0-RC2 --- No new revisions were added by this update. Summary of changes:
[beam] annotated tag sdks/v2.36.0-RC2 updated (832a000 -> 3b38a28)
This is an automated email from the ASF dual-hosted git repository. emilyye pushed a change to annotated tag sdks/v2.36.0-RC2 in repository https://gitbox.apache.org/repos/asf/beam.git. *** WARNING: tag sdks/v2.36.0-RC2 was modified! *** from 832a000 (commit) to 3b38a28 (tag) tagging 832a000b3d02eb6e6454cb8e97c0d24535f2e975 (commit) replaces jupyterlab-sidepanel-v2.0.0 by Emily Ye on Thu Feb 3 17:52:47 2022 + - Log - Go SDK v2.36.0-RC2 --- No new revisions were added by this update. Summary of changes:
[beam] branch master updated: [BEAM-13757] adds pane observation in DoFn (#16629)
This is an automated email from the ASF dual-hosted git repository.
lostluck pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push:
new 32a0f09 [BEAM-13757] adds pane observation in DoFn (#16629)
32a0f09 is described below
commit 32a0f09b61d4146d48e5ba7d4f3433d9df98d586
Author: Ritesh Ghorse
AuthorDate: Thu Feb 3 13:44:55 2022 -0500
[BEAM-13757] adds pane observation in DoFn (#16629)
---
sdks/go/pkg/beam/core/funcx/fn.go | 39 ++-
sdks/go/pkg/beam/core/funcx/fn_test.go | 104 +-
sdks/go/pkg/beam/core/runtime/exec/decode.go | 2 +-
sdks/go/pkg/beam/core/runtime/exec/fn.go | 48
sdks/go/pkg/beam/core/runtime/exec/fn_arity.go | 122 ++---
sdks/go/pkg/beam/core/runtime/exec/fn_arity.tmpl | 14 +--
sdks/go/pkg/beam/core/runtime/exec/fn_test.go | 6 +-
sdks/go/pkg/beam/core/runtime/exec/pardo.go| 16 +--
sdks/go/test/integration/integration.go| 15 ++-
.../go/test/integration/primitives/window_panes.go | 51 +
.../integration/primitives/window_panes_test.go| 31 ++
11 files changed, 336 insertions(+), 112 deletions(-)
diff --git a/sdks/go/pkg/beam/core/funcx/fn.go
b/sdks/go/pkg/beam/core/funcx/fn.go
index 97ca76a..55fbc25 100644
--- a/sdks/go/pkg/beam/core/funcx/fn.go
+++ b/sdks/go/pkg/beam/core/funcx/fn.go
@@ -17,9 +17,9 @@ package funcx
import (
"fmt"
- "github.com/apache/beam/sdks/v2/go/pkg/beam/core/sdf"
"reflect"
+ "github.com/apache/beam/sdks/v2/go/pkg/beam/core/sdf"
"github.com/apache/beam/sdks/v2/go/pkg/beam/core/typex"
"github.com/apache/beam/sdks/v2/go/pkg/beam/core/util/reflectx"
"github.com/apache/beam/sdks/v2/go/pkg/beam/internal/errors"
@@ -76,6 +76,8 @@ const (
// Example:
// "func(string) func (*int) bool"
FnMultiMap FnParamKind = 0x200
+ // FnPane indicates a function input parameter that is a PaneInfo
+ FnPane FnParamKind = 0x400
)
func (k FnParamKind) String() string {
@@ -100,6 +102,8 @@ func (k FnParamKind) String() string {
return "RTracker"
case FnMultiMap:
return "MultiMap"
+ case FnPane:
+ return "Pane"
default:
return fmt.Sprintf("%v", int(k))
}
@@ -243,6 +247,16 @@ func (u *Fn) Window() (pos int, exists bool) {
return -1, false
}
+// Pane returns (index, true) iff the function expects a PaneInfo.
+func (u *Fn) Pane() (pos int, exists bool) {
+ for i, p := range u.Param {
+ if p.Kind == FnPane {
+ return i, true
+ }
+ }
+ return -1, false
+}
+
// RTracker returns (index, true) iff the function expects an sdf.RTracker.
func (u *Fn) RTracker() (pos int, exists bool) {
for i, p := range u.Param {
@@ -329,6 +343,8 @@ func New(fn reflectx.Func) (*Fn, error) {
kind = FnReIter
case IsMultiMap(t):
kind = FnMultiMap
+ case t == typex.PaneInfoType:
+ kind = FnPane
default:
return nil, errors.Errorf("bad parameter type for %s:
%v", fn.Name(), t)
}
@@ -386,7 +402,7 @@ func SubReturns(list []ReturnParam, indices ...int)
[]ReturnParam {
}
// The order of present parameters and return values must be as follows:
-// func(FnContext?, FnWindow?, FnEventTime?, FnType?, FnRTracker?, (FnValue,
SideInput*)?, FnEmit*) (RetEventTime?, RetOutput?, RetError?)
+// func(FnContext?, FnPane?, FnWindow?, FnEventTime?, FnType?, FnRTracker?,
(FnValue, SideInput*)?, FnEmit*) (RetEventTime?, RetOutput?, RetError?)
// where ? indicates 0 or 1, and * indicates any number.
// and a SideInput is one of FnValue or FnIter or FnReIter
// Note: Fns with inputs must have at least one FnValue as the main input.
@@ -411,6 +427,7 @@ func validateOrder(u *Fn) error {
var (
errContextParam = errors.New("may only have a single
context.Context parameter and it must be the first parameter")
+ errPaneParamPrecedence = errors.New("may only have a single
PaneInfo parameter and it must precede the WindowParam, EventTime and main
input parameter")
errWindowParamPrecedence= errors.New("may only have a single Window
parameter and it must precede the EventTime and main input parameter")
errEventTimeParamPrecedence = errors.New("may only have a single
beam.EventTime parameter and it must precede the main input parameter")
errReflectTypePrecedence= errors.New("may only have a single
reflect.Type parameter and it must precede the main input parameter")
@@ -423,6 +440,7 @@ type paramState int
const (
psStart paramState = iota
[beam] branch master updated (32a0f09 -> 6814a06)
This is an automated email from the ASF dual-hosted git repository. reuvenlax pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from 32a0f09 [BEAM-13757] adds pane observation in DoFn (#16629) add 8ea77f9 Fix timer consistency in direct runner add 6814a06 Merge pull request #16650:[BEAM-11971] Fix directrunner timer consistency No new revisions were added by this update. Summary of changes: .../apache/beam/runners/core/TimerInternals.java | 17 +- .../beam/runners/direct/DirectTimerInternals.java | 72 +++--- .../direct/ExecutorServiceParallelExecutor.java| 2 +- .../beam/runners/direct/QuiescenceDriver.java | 78 --- .../direct/StatefulParDoEvaluatorFactory.java | 83 --- .../beam/runners/direct/WatermarkManager.java | 250 + .../apache/beam/runners/local/ExecutionDriver.java | 2 +- .../org/apache/beam/sdk/transforms/ParDoTest.java | 10 +- 8 files changed, 232 insertions(+), 282 deletions(-)
svn commit: r52382 - in /dev/beam/2.36.0: apache-beam-2.36.0-source-release.zip apache-beam-2.36.0-source-release.zip.asc apache-beam-2.36.0-source-release.zip.sha512
Author: emilyye Date: Thu Feb 3 19:21:31 2022 New Revision: 52382 Log: Staging Java artifacts for Apache Beam 2.36.0 RC2 Added: dev/beam/2.36.0/apache-beam-2.36.0-source-release.zip (with props) Modified: dev/beam/2.36.0/apache-beam-2.36.0-source-release.zip.asc dev/beam/2.36.0/apache-beam-2.36.0-source-release.zip.sha512 Added: dev/beam/2.36.0/apache-beam-2.36.0-source-release.zip == Binary file - no diff available. Propchange: dev/beam/2.36.0/apache-beam-2.36.0-source-release.zip -- svn:mime-type = application/octet-stream Modified: dev/beam/2.36.0/apache-beam-2.36.0-source-release.zip.asc == --- dev/beam/2.36.0/apache-beam-2.36.0-source-release.zip.asc (original) +++ dev/beam/2.36.0/apache-beam-2.36.0-source-release.zip.asc Thu Feb 3 19:21:31 2022 @@ -1,16 +1,16 @@ -BEGIN PGP SIGNATURE- -iQIzBAABCgAdFiEEcw1ejUyoEMHwHTBLYQs4qhvhFlYFAmH4znAACgkQYQs4qhvh -FlZMvRAAkPrl4falYeI4tBExbRa1jI1vDJCexgIPDHvHvFt0uLC7yklMcYdja0HD -+ab5T1r93qXEzfFPcQBoP4bA5h6DnShKaYqKERALB5Ex33rQxdjNBU4Q8nOhncEu -Mdf2G9Cb9NXZrP4xqkxio+WtmfLt4OwAsnGtBy3SiUkG2pkcjFvPhs0iYG6dcKqg -0wvD8fODLL+VTlqG5Wsbtyca2QtuMnD6tYb3247sej3QzWQCuPNuIrYBBaOlvfNX -AL+SP0XP9DNu79tMvTDBwsVfbQMBhHFIo7Wa1TsJXgI8rbfmS1JL7qNfzqkM5k8t -Z3ma7khy6FAZfperSryvehGCqbvpxXQAb9osG5JCCM0gQGa/rj7hx5NtF5AtCJpz -mRtldeSJUHY2eo94CK0zhM87nWvRu6I5TkOtNpEnLLyqsdxyVenJcMFUbKR0HNge -Gj415hgxH3t0yIdPc8DxQplhtlIFv9LQ0Ao0D60lAHdIiQALaXlvRI6rd3Zp5pAj -j3LmtfR0GBQKhf8IhbHVV2VD5kbSmg29aQFJKG4YMNmwM2dDG9h2OOSuOU7x0i7e -sJfH2yM+nDVm1ObCnAjECKfNUogj6nWRqeOwjgu11+SxZCeiczcrckEJBkh1V/JA -B5tUVSVUxiDAaDrj+NKPz/g31VJ8jfV13bZhGrGWW2PUw9nJa+Y= -=6E0V +iQIzBAABCgAdFiEEcw1ejUyoEMHwHTBLYQs4qhvhFlYFAmH8Kx8ACgkQYQs4qhvh +FlZU8Q/8CnaYxHJnW7OUMuC+wRQV13SuUaHnh12h2vy6+iI1OAv8z9fdige7t6LX +FWQJxbdHJKj5BuKNRGcuqUgdjkvtiYP21Uo4xZg5T+7QUMrRRCWRWfYhHkekyhPN +4vtYgmrQ0mShgqqMf9eCCGLLjWyBYj99q+JL4kyAXXR0dxYucXdGIpFBr7uqnmGZ +InhIFbKm8IBBjguBj9S7ms6bqHOSfPmNkqnX2wUWTl+MyM6MCv1TaoeiPXIPjXjA +BCQUCuDYljW48LvVz72uXhX2jSxL2gjqoyx825Aj2AXqbifsOiVTBuf6QIiL2UvO +CH1fHXt5I9B7g0Zq8VjJFQtmPgl3ItslzyoQWE6dH8SuFpSqzsbI/LqNfDeQvAtM +VeXw0JWT8gSH9bkgxsP6FlLjn8M02aFO3nSDNP8rfuDTkn03/rUWXx4x5Es2hRsK +TRISoZHb4XlUPC7CIXCa1DxknSDat1DHDIL/H5SCRyWtbt83eOxFwtd3Y0G7P9ur +ixM+7akm3hn9lczoDniCXwNuxkyHrQGFnESqbq8kG8uwi/jbzPZ81v+f6e2nbPxN +W3xxK60ze89nnBQ+YUfUavPsO8xk6ZgulLeSQ9S6eq0Yq01smF8hDgbkiD+iqIYY +srgFWsya+Qz0dfo/l3sUyDIns4qAfdIDSXXNAIelH+DkreCSdng= +=kERK -END PGP SIGNATURE- Modified: dev/beam/2.36.0/apache-beam-2.36.0-source-release.zip.sha512 == --- dev/beam/2.36.0/apache-beam-2.36.0-source-release.zip.sha512 (original) +++ dev/beam/2.36.0/apache-beam-2.36.0-source-release.zip.sha512 Thu Feb 3 19:21:31 2022 @@ -1 +1 @@ -2f642f15a45e62b94353ffd69267de110d496e207883be4b99d6e7fbc4f2d2cf01721eddacbab65a85624c69c3a26b25238944e8772526734544a7ce1f2206f9 apache-beam-2.36.0-source-release.zip +dc303474d4de58c6060bb9e7b5845f920b2ef5fa0aa5b8ede87a2a61f2eaca8713f2000bc69d71c41ae620116b301268d738a0d1a595a0bfc0c08c9cc0fd9311 apache-beam-2.36.0-source-release.zip
[beam] branch master updated (6814a06 -> 5beae2a)
This is an automated email from the ASF dual-hosted git repository. bhulette pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from 6814a06 Merge pull request #16650:[BEAM-11971] Fix directrunner timer consistency add 5beae2a [BEAM-13605] Add support for pandas 1.4.0 (#16590) No new revisions were added by this update. Summary of changes: CHANGES.md | 18 sdks/python/apache_beam/dataframe/frames.py| 27 +++-- sdks/python/apache_beam/dataframe/io_test.py | 8 + .../apache_beam/dataframe/pandas_doctests_test.py | 34 +- sdks/python/setup.py | 2 +- sdks/python/test-suites/tox/py38/build.gradle | 4 +++ sdks/python/tox.ini| 3 +- 7 files changed, 91 insertions(+), 5 deletions(-)
[beam] branch master updated (5beae2a -> 9434c4d)
This is an automated email from the ASF dual-hosted git repository. iemejia pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from 5beae2a [BEAM-13605] Add support for pandas 1.4.0 (#16590) add 99b903f Change links to Books from Amazon to Publisher add 9434c4d Merge pull request #16718: [website] Change links to Books from Amazon to Publisher No new revisions were added by this update. Summary of changes: .../www/site/content/en/documentation/resources/learning-resources.md | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-)
svn commit: r52387 - /dev/beam/2.36.0/python/
Author: emilyye Date: Thu Feb 3 23:19:39 2022 New Revision: 52387 Log: Staging Python artifacts for Apache Beam 2.36.0 RC2 Modified: dev/beam/2.36.0/python/apache-beam-2.36.0.zip dev/beam/2.36.0/python/apache-beam-2.36.0.zip.asc dev/beam/2.36.0/python/apache-beam-2.36.0.zip.sha512 dev/beam/2.36.0/python/apache_beam-2.36.0-cp36-cp36m-macosx_10_9_x86_64.whl dev/beam/2.36.0/python/apache_beam-2.36.0-cp36-cp36m-macosx_10_9_x86_64.whl.asc dev/beam/2.36.0/python/apache_beam-2.36.0-cp36-cp36m-macosx_10_9_x86_64.whl.sha512 dev/beam/2.36.0/python/apache_beam-2.36.0-cp36-cp36m-manylinux1_i686.whl dev/beam/2.36.0/python/apache_beam-2.36.0-cp36-cp36m-manylinux1_i686.whl.asc dev/beam/2.36.0/python/apache_beam-2.36.0-cp36-cp36m-manylinux1_i686.whl.sha512 dev/beam/2.36.0/python/apache_beam-2.36.0-cp36-cp36m-manylinux1_x86_64.whl dev/beam/2.36.0/python/apache_beam-2.36.0-cp36-cp36m-manylinux1_x86_64.whl.asc dev/beam/2.36.0/python/apache_beam-2.36.0-cp36-cp36m-manylinux1_x86_64.whl.sha512 dev/beam/2.36.0/python/apache_beam-2.36.0-cp36-cp36m-manylinux2010_i686.whl dev/beam/2.36.0/python/apache_beam-2.36.0-cp36-cp36m-manylinux2010_i686.whl.asc dev/beam/2.36.0/python/apache_beam-2.36.0-cp36-cp36m-manylinux2010_i686.whl.sha512 dev/beam/2.36.0/python/apache_beam-2.36.0-cp36-cp36m-manylinux2010_x86_64.whl dev/beam/2.36.0/python/apache_beam-2.36.0-cp36-cp36m-manylinux2010_x86_64.whl.asc dev/beam/2.36.0/python/apache_beam-2.36.0-cp36-cp36m-manylinux2010_x86_64.whl.sha512 dev/beam/2.36.0/python/apache_beam-2.36.0-cp36-cp36m-manylinux2014_aarch64.whl dev/beam/2.36.0/python/apache_beam-2.36.0-cp36-cp36m-manylinux2014_aarch64.whl.asc dev/beam/2.36.0/python/apache_beam-2.36.0-cp36-cp36m-manylinux2014_aarch64.whl.sha512 dev/beam/2.36.0/python/apache_beam-2.36.0-cp36-cp36m-win32.whl dev/beam/2.36.0/python/apache_beam-2.36.0-cp36-cp36m-win32.whl.asc dev/beam/2.36.0/python/apache_beam-2.36.0-cp36-cp36m-win32.whl.sha512 dev/beam/2.36.0/python/apache_beam-2.36.0-cp36-cp36m-win_amd64.whl dev/beam/2.36.0/python/apache_beam-2.36.0-cp36-cp36m-win_amd64.whl.asc dev/beam/2.36.0/python/apache_beam-2.36.0-cp36-cp36m-win_amd64.whl.sha512 dev/beam/2.36.0/python/apache_beam-2.36.0-cp37-cp37m-macosx_10_9_x86_64.whl dev/beam/2.36.0/python/apache_beam-2.36.0-cp37-cp37m-macosx_10_9_x86_64.whl.asc dev/beam/2.36.0/python/apache_beam-2.36.0-cp37-cp37m-macosx_10_9_x86_64.whl.sha512 dev/beam/2.36.0/python/apache_beam-2.36.0-cp37-cp37m-manylinux1_i686.whl dev/beam/2.36.0/python/apache_beam-2.36.0-cp37-cp37m-manylinux1_i686.whl.asc dev/beam/2.36.0/python/apache_beam-2.36.0-cp37-cp37m-manylinux1_i686.whl.sha512 dev/beam/2.36.0/python/apache_beam-2.36.0-cp37-cp37m-manylinux1_x86_64.whl dev/beam/2.36.0/python/apache_beam-2.36.0-cp37-cp37m-manylinux1_x86_64.whl.asc dev/beam/2.36.0/python/apache_beam-2.36.0-cp37-cp37m-manylinux1_x86_64.whl.sha512 dev/beam/2.36.0/python/apache_beam-2.36.0-cp37-cp37m-manylinux2010_i686.whl dev/beam/2.36.0/python/apache_beam-2.36.0-cp37-cp37m-manylinux2010_i686.whl.asc dev/beam/2.36.0/python/apache_beam-2.36.0-cp37-cp37m-manylinux2010_i686.whl.sha512 dev/beam/2.36.0/python/apache_beam-2.36.0-cp37-cp37m-manylinux2010_x86_64.whl dev/beam/2.36.0/python/apache_beam-2.36.0-cp37-cp37m-manylinux2010_x86_64.whl.asc dev/beam/2.36.0/python/apache_beam-2.36.0-cp37-cp37m-manylinux2010_x86_64.whl.sha512 dev/beam/2.36.0/python/apache_beam-2.36.0-cp37-cp37m-manylinux2014_aarch64.whl dev/beam/2.36.0/python/apache_beam-2.36.0-cp37-cp37m-manylinux2014_aarch64.whl.asc dev/beam/2.36.0/python/apache_beam-2.36.0-cp37-cp37m-manylinux2014_aarch64.whl.sha512 dev/beam/2.36.0/python/apache_beam-2.36.0-cp37-cp37m-win32.whl dev/beam/2.36.0/python/apache_beam-2.36.0-cp37-cp37m-win32.whl.asc dev/beam/2.36.0/python/apache_beam-2.36.0-cp37-cp37m-win32.whl.sha512 dev/beam/2.36.0/python/apache_beam-2.36.0-cp37-cp37m-win_amd64.whl dev/beam/2.36.0/python/apache_beam-2.36.0-cp37-cp37m-win_amd64.whl.asc dev/beam/2.36.0/python/apache_beam-2.36.0-cp37-cp37m-win_amd64.whl.sha512 dev/beam/2.36.0/python/apache_beam-2.36.0-cp38-cp38-macosx_10_9_x86_64.whl dev/beam/2.36.0/python/apache_beam-2.36.0-cp38-cp38-macosx_10_9_x86_64.whl.asc dev/beam/2.36.0/python/apache_beam-2.36.0-cp38-cp38-macosx_10_9_x86_64.whl.sha512 dev/beam/2.36.0/python/apache_beam-2.36.0-cp38-cp38-manylinux1_i686.whl dev/beam/2.36.0/python/apache_beam-2.36.0-cp38-cp38-manylinux1_i686.whl.asc dev/beam/2.36.0/python/apache_beam-2.36.0-cp38-cp38-manylinux1_i686.whl.sha512 dev/beam/2.36.0/python/apache_beam-2.36.0-cp38-cp38-manylinux1_x86_64.whl dev/beam/2.36.0/python/apache_beam-2.36.0-cp38-cp38-manylinux1_x86_64.whl.asc dev/beam/2.36.0/python/apache_beam-2.36.0-cp38-cp38-manylinux1_x86_64.whl.sha512 dev/beam/2.36.0/python/apache_beam-2.36.0-cp3
[beam] branch master updated (9434c4d -> b26988c)
This is an automated email from the ASF dual-hosted git repository.
lostluck pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 9434c4d Merge pull request #16718: [website] Change links to Books
from Amazon to Publisher
add b26988c [BEAM-13761] adds Debezium IO wrapper for Go SDK (#16642)
No new revisions were added by this update.
Summary of changes:
sdks/go.sum| 2 +
sdks/go/pkg/beam/io/xlang/debeziumio/debezium.go | 138 +
sdks/go/test/integration/integration.go| 4 +
.../test/integration/io/xlang/debezium/debezium.go | 35 ++
.../jdbc_test.go => debezium/debezium_test.go} | 60 +++--
5 files changed, 199 insertions(+), 40 deletions(-)
create mode 100644 sdks/go/pkg/beam/io/xlang/debeziumio/debezium.go
create mode 100644 sdks/go/test/integration/io/xlang/debezium/debezium.go
copy sdks/go/test/integration/io/xlang/{jdbc/jdbc_test.go =>
debezium/debezium_test.go} (59%)
[beam] branch asf-site updated: Publishing website 2022/02/04 00:06:48 at commit b26988c
This is an automated email from the ASF dual-hosted git repository.
git-site-role pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/asf-site by this push:
new 170274f Publishing website 2022/02/04 00:06:48 at commit b26988c
170274f is described below
commit 170274fbe7be0a6c8f714b63c832e51da5c80d04
Author: jenkins
AuthorDate: Fri Feb 4 00:06:49 2022 +
Publishing website 2022/02/04 00:06:48 at commit b26988c
---
.../documentation/resources/learning-resources/index.html | 4 ++--
website/generated-content/sitemap.xml | 2 +-
2 files changed, 3 insertions(+), 3 deletions(-)
diff --git
a/website/generated-content/documentation/resources/learning-resources/index.html
b/website/generated-content/documentation/resources/learning-resources/index.html
index b982769..4a23dca 100644
---
a/website/generated-content/documentation/resources/learning-resources/index.html
+++
b/website/generated-content/documentation/resources/learning-resources/index.html
@@ -18,12 +18,12 @@
function addPlaceholder(){$('input:text').attr('placeholder',"What are you
looking for?");}
function endSearch(){var
search=document.querySelector(".searchBar");search.classList.add("disappear");var
icons=document.querySelector("#iconsBar");icons.classList.remove("disappear");}
function blockScroll(){$("body").toggleClass("fixedPosition");}
-function openMenu(){addPlaceholder();blockScroll();}DocumentationUsing the DocumentationDocumentationUsing the Documentationhttps://www.jetbrains.com/education/>JetBrains
Educational Products, Beam Katas
objective is to provide a series of structured hands-on learning experiences
for learners
to understand about Apache Beam and its SDKs by solving exercises with
gradually increasing
-complexity. Beam Katas are available for both Java and Python SDKs.JavaDownload https://www.jetbrains.com/education/download/#section=idea";>IntelliJ
EduUpon opening the IDE, expand the “Learn and Teach”
menu, then select “Browse Courses”Search for “Beam
Katas - Java”Expand the “Advanced Settings” and
modify the “Location” and “Jdk” appropriatelyJavaDownload https://www.jetbrains.com/education/download/#section=idea";>IntelliJ
EduUpon opening the IDE, expand the “Learn and Teach”
menu, then select “Browse Courses”Search for “Beam
Katas - Java”Expand the “Advanced Settings” and
modify the “Location” and “Jdk” appropriatelyhttp://www.apache.org>The Apache Software Foundation
| Privacy Policy
| RSS FeedApache Beam, Apache, Beam, the Beam
logo, and the Apache feather logo are either registered trademarks or
trademarks of The Apache Software Foundation. All other products or name brands
are trademarks of their respective holders, including The Apache Software
Foundation.
\ No newline at end of file
diff --git a/website/generated-content/sitemap.xml
b/website/generated-content/sitemap.xml
index fb7d19f..3cc3873 100644
--- a/website/generated-content/sitemap.xml
+++ b/website/generated-content/sitemap.xml
@@ -1 +1 @@
-http://www.sitemaps.org/schemas/sitemap/0.9";
xmlns:xhtml="http://www.w3.org/1999/xhtml";>/blog/beam-2.35.0/2021-12-29T17:49:39-08:00/categories/blog/2021-12-29T17:49:39-08:00/blog/2021-12-29T17:49:39-08:00/categories/2021-12-29T17:49:39-08:00/blog/b
[...]
\ No newline at end of file
+http://www.sitemaps.org/schemas/sitemap/0.9";
xmlns:xhtml="http://www.w3.org/1999/xhtml";>/blog/beam-2.35.0/2021-12-29T17:49:39-08:00/categories/blog/2021-12-29T17:49:39-08:00/blog/2021-12-29T17:49:39-08:00/categories/2021-12-29T17:49:39-08:00/blog/b
[...]
\ No newline at end of file
[beam] branch master updated (b26988c -> 07aa907)
This is an automated email from the ASF dual-hosted git repository.
kileysok pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from b26988c [BEAM-13761] adds Debezium IO wrapper for Go SDK (#16642)
new 5c5a06f Allow Java 17 to be used in SDK
new 02d442d add testing support
new 3f5ab6a Add more testing support for java 17
new 65e6437 workaround for jamm
new f396331 Add Jenkins test for Java 17
new e0be225 Fix jvm hex and skip errorprone
new dbd9b2c Fix display data for anonymous classes
new 4344afb fix jpms tests
new c1ff03b skip zetasql
new 6c54ae0 Merge branch 'master' of github.com:apache/beam into
java7tests
new 0422e20 spotless
new 28280ee spotless
new 88365f6 Merge branch 'master' of github.com:apache/beam into
java7tests
new bda7732 Fix trigger
new 5b3b3d0 skip checker framework
new 74557c5 fix app name
new a847c1c remove duplicate property check
new 940d4f3 Merge branch 'master' of github.com:apache/beam into
java7tests
new 07aa907 Merge pull request #16640 from kileys/java7tests
The 34466 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
... job_LoadTests_CoGBK_Dataflow_V2_Java17.groovy} | 38
...=> job_LoadTests_GBK_Dataflow_V2_Java17.groovy} | 50 +++---
... job_LoadTests_ParDo_Dataflow_V2_Java17.groovy} | 38
...ostCommit_Java_Dataflow_Examples_Java17.groovy} | 8 ++--
...Commit_Java_Examples_Dataflow_V2_Java17.groovy} | 10 ++---
...ob_PostCommit_Java_Jpms_Dataflow_Java17.groovy} | 10 +++--
... job_PostCommit_Java_Jpms_Direct_Java17.groovy} | 10 +++--
...tCommit_Java_Nexmark_Dataflow_V2_Java17.groovy} | 18
...it_Java_ValidatesRunner_Dataflow_Java17.groovy} | 13 +++---
...mmit_Java_ValidatesRunner_Direct_Java17.groovy} | 14 +++---
...va11.groovy => job_PreCommit_SQL_Java17.groovy} | 9 ++--
...Precommit_Java_Examples_Dataflow_Java17.groovy} | 10 ++---
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 50 --
.../beam/sdk/transforms/display/DisplayData.java | 9 +++-
sdks/java/testing/jpms-tests/build.gradle | 30 -
.../org/apache/beam/sdk/jpmstests/WordCount.java | 8
.../testutils/jvmverification/JvmVerification.java | 2 +-
17 files changed, 194 insertions(+), 133 deletions(-)
copy .test-infra/jenkins/{job_LoadTests_CoGBK_Dataflow_V2_Java11.groovy =>
job_LoadTests_CoGBK_Dataflow_V2_Java17.groovy} (90%)
copy .test-infra/jenkins/{job_LoadTests_GBK_Dataflow_V2_Java11.groovy =>
job_LoadTests_GBK_Dataflow_V2_Java17.groovy} (89%)
copy .test-infra/jenkins/{job_LoadTests_ParDo_Dataflow_V2_Java11.groovy =>
job_LoadTests_ParDo_Dataflow_V2_Java17.groovy} (88%)
copy .test-infra/jenkins/{job_PostCommit_Java_Dataflow_Examples_Java11.groovy
=> job_PostCommit_Java_Dataflow_Examples_Java17.groovy} (89%)
copy
.test-infra/jenkins/{job_PostCommit_Java_Examples_Dataflow_V2_Java11.groovy =>
job_PostCommit_Java_Examples_Dataflow_V2_Java17.groovy} (87%)
copy .test-infra/jenkins/{job_PostCommit_Java_Jpms_Dataflow_Java11.groovy =>
job_PostCommit_Java_Jpms_Dataflow_Java17.groovy} (83%)
copy .test-infra/jenkins/{job_PostCommit_Java_Jpms_Direct_Java11.groovy =>
job_PostCommit_Java_Jpms_Direct_Java17.groovy} (85%)
copy .test-infra/jenkins/{job_PostCommit_Java_Nexmark_Dataflow_V2.groovy =>
job_PostCommit_Java_Nexmark_Dataflow_V2_Java17.groovy} (85%)
copy
.test-infra/jenkins/{job_PostCommit_Java_ValidatesRunner_Dataflow_Java11.groovy
=> job_PostCommit_Java_ValidatesRunner_Dataflow_Java17.groovy} (82%)
copy
.test-infra/jenkins/{job_PostCommit_Java_ValidatesRunner_Direct_Java11.groovy
=> job_PostCommit_Java_ValidatesRunner_Direct_Java17.groovy} (80%)
copy .test-infra/jenkins/{job_PreCommit_SQL_Java11.groovy =>
job_PreCommit_SQL_Java17.groovy} (91%)
copy .test-infra/jenkins/{job_PreCommit_Java_Examples_Dataflow_Java11.groovy
=> job_Precommit_Java_Examples_Dataflow_Java17.groovy} (87%)
[beam] branch master updated (07aa907 -> 8da6363)
This is an automated email from the ASF dual-hosted git repository. lostluck pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from 07aa907 Merge pull request #16640 from kileys/java7tests add 8da6363 [BEAM-13024] Unify PipelineOptions behavior (#16719) No new revisions were added by this update. Summary of changes: sdks/go/pkg/beam/core/runtime/options.go | 18 sdks/go/pkg/beam/core/runtime/options_test.go | 33 +- sdks/go/pkg/beam/runners/dataflow/dataflow.go | 8 +- sdks/go/pkg/beam/runners/direct/direct.go | 1 + .../go/pkg/beam/runners/universal/runnerlib/job.go | 1 + sdks/go/test/integration/primitives/pardo.go | 25 sdks/go/test/integration/primitives/pardo_test.go | 5 7 files changed, 83 insertions(+), 8 deletions(-)
[beam] annotated tag sdks/v2.36.0-RC3 updated (81f3a16 -> a521ba9)
This is an automated email from the ASF dual-hosted git repository. emilyye pushed a change to annotated tag sdks/v2.36.0-RC3 in repository https://gitbox.apache.org/repos/asf/beam.git. *** WARNING: tag sdks/v2.36.0-RC3 was modified! *** from 81f3a16 (commit) to a521ba9 (tag) tagging 81f3a16bccce6b2a5cb0978e71856ea53eb3bbde (commit) replaces jupyterlab-sidepanel-v2.0.0 by Emily Ye on Fri Feb 4 03:13:25 2022 + - Log - Go SDK v2.36.0-RC3 --- No new revisions were added by this update. Summary of changes:
[beam] annotated tag v2.36.0-RC3 updated (81f3a16 -> cb30abe)
This is an automated email from the ASF dual-hosted git repository. emilyye pushed a change to annotated tag v2.36.0-RC3 in repository https://gitbox.apache.org/repos/asf/beam.git. *** WARNING: tag v2.36.0-RC3 was modified! *** from 81f3a16 (commit) to cb30abe (tag) tagging 81f3a16bccce6b2a5cb0978e71856ea53eb3bbde (commit) replaces jupyterlab-sidepanel-v2.0.0 by Emily Ye on Fri Feb 4 03:13:25 2022 + - Log - v2.36.0-RC3 --- No new revisions were added by this update. Summary of changes:
[beam] branch master updated (8da6363 -> 9787598)
This is an automated email from the ASF dual-hosted git repository. heejong pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from 8da6363 [BEAM-13024] Unify PipelineOptions behavior (#16719) new 8050266 [BEAM-13813] Add support for URL artifact to extractStagingToPath new 723eded Update sdks/go/pkg/beam/artifact/materialize_test.go new 9787598 Merge pull request #16710 from ihji/BEAM-13813 The 34470 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: sdks/go/pkg/beam/artifact/materialize.go | 14 sdks/go/pkg/beam/artifact/materialize_test.go | 97 +-- 2 files changed, 105 insertions(+), 6 deletions(-)
[beam] branch nightly-refs/heads/master updated (51e0e4e -> 8da6363)
This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch nightly-refs/heads/master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 51e0e4e [BEAM-13605] Modify groupby.apply implementation in
preparation for pandas 1.4.0 (#16706)
add 9794fb4 Merge pull request #16436 from [BEAM-1330] - DatastoreIO
Writes should flush early when duplicate keys arrive
add 32a0f09 [BEAM-13757] adds pane observation in DoFn (#16629)
add 8ea77f9 Fix timer consistency in direct runner
add 6814a06 Merge pull request #16650:[BEAM-11971] Fix directrunner timer
consistency
add 5beae2a [BEAM-13605] Add support for pandas 1.4.0 (#16590)
add 99b903f Change links to Books from Amazon to Publisher
add 9434c4d Merge pull request #16718: [website] Change links to Books
from Amazon to Publisher
add b26988c [BEAM-13761] adds Debezium IO wrapper for Go SDK (#16642)
add 5c5a06f Allow Java 17 to be used in SDK
add 02d442d add testing support
add 3f5ab6a Add more testing support for java 17
add 65e6437 workaround for jamm
add f396331 Add Jenkins test for Java 17
add e0be225 Fix jvm hex and skip errorprone
add dbd9b2c Fix display data for anonymous classes
add 4344afb fix jpms tests
add c1ff03b skip zetasql
add 6c54ae0 Merge branch 'master' of github.com:apache/beam into
java7tests
add 0422e20 spotless
add 28280ee spotless
add 88365f6 Merge branch 'master' of github.com:apache/beam into
java7tests
add bda7732 Fix trigger
add 5b3b3d0 skip checker framework
add 74557c5 fix app name
add a847c1c remove duplicate property check
add 940d4f3 Merge branch 'master' of github.com:apache/beam into
java7tests
add 07aa907 Merge pull request #16640 from kileys/java7tests
add 8da6363 [BEAM-13024] Unify PipelineOptions behavior (#16719)
No new revisions were added by this update.
Summary of changes:
.../job_LoadTests_CoGBK_Dataflow_V2_Java17.groovy | 246
.../job_LoadTests_GBK_Dataflow_V2_Java17.groovy| 311 +
.../job_LoadTests_ParDo_Dataflow_V2_Java17.groovy | 217 ++
...PostCommit_Java_Dataflow_Examples_Java17.groovy | 46 +++
...tCommit_Java_Examples_Dataflow_V2_Java17.groovy | 50
...job_PostCommit_Java_Jpms_Dataflow_Java17.groovy | 51
.../job_PostCommit_Java_Jpms_Direct_Java17.groovy | 51
...stCommit_Java_Nexmark_Dataflow_V2_Java17.groovy | 67 +
...mit_Java_ValidatesRunner_Dataflow_Java17.groovy | 57
...ommit_Java_ValidatesRunner_Direct_Java17.groovy | 55
.../jenkins/job_PreCommit_SQL_Java17.groovy| 55
..._Precommit_Java_Examples_Dataflow_Java17.groovy | 56
CHANGES.md | 18 ++
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 50 +++-
.../apache/beam/runners/core/TimerInternals.java | 17 +-
.../beam/runners/direct/DirectTimerInternals.java | 72 ++---
.../direct/ExecutorServiceParallelExecutor.java| 2 +-
.../beam/runners/direct/QuiescenceDriver.java | 78 +++---
.../direct/StatefulParDoEvaluatorFactory.java | 83 +++---
.../beam/runners/direct/WatermarkManager.java | 250 +++--
.../apache/beam/runners/local/ExecutionDriver.java | 2 +-
sdks/go.sum| 2 +
sdks/go/pkg/beam/core/funcx/fn.go | 39 ++-
sdks/go/pkg/beam/core/funcx/fn_test.go | 104 ++-
sdks/go/pkg/beam/core/runtime/exec/decode.go | 2 +-
sdks/go/pkg/beam/core/runtime/exec/fn.go | 48 ++--
sdks/go/pkg/beam/core/runtime/exec/fn_arity.go | 122
sdks/go/pkg/beam/core/runtime/exec/fn_arity.tmpl | 14 +-
sdks/go/pkg/beam/core/runtime/exec/fn_test.go | 6 +-
sdks/go/pkg/beam/core/runtime/exec/pardo.go| 16 +-
sdks/go/pkg/beam/core/runtime/options.go | 18 ++
sdks/go/pkg/beam/core/runtime/options_test.go | 33 ++-
sdks/go/pkg/beam/io/xlang/debeziumio/debezium.go | 138 +
sdks/go/pkg/beam/runners/dataflow/dataflow.go | 8 +-
sdks/go/pkg/beam/runners/direct/direct.go | 1 +
.../go/pkg/beam/runners/universal/runnerlib/job.go | 1 +
sdks/go/test/integration/integration.go| 19 +-
.../test/integration/io/xlang/debezium/debezium.go | 35 +++
.../integration/io/xlang/debezium/debezium_test.go | 93 ++
sdks/go/test/integration/primitives/pardo.go | 25 ++
sdks/go/test/integration/primitives/pardo_test.go | 5 +
.../go/test/integration/primitives/window_panes.go | 51
.../{pardo_test.go => window_panes_test.go}| 22 +-
.../beam/sdk/transforms/display/DisplayData.java | 9 +-
.../org/apache/beam/sdk/transforms/ParDoTest.java | 10 +-
.../beam/sdk/io/gcp/datastore/DatastoreV1.java | 13 +-
.../beam/sdk/io/gcp/datastore/V1WriteIT.java |
svn commit: r52391 - in /dev/beam/2.36.0: apache-beam-2.36.0-source-release.zip apache-beam-2.36.0-source-release.zip.asc apache-beam-2.36.0-source-release.zip.sha512
Author: emilyye Date: Fri Feb 4 05:07:24 2022 New Revision: 52391 Log: Staging Java artifacts for Apache Beam 2.36.0 RC3 Added: dev/beam/2.36.0/apache-beam-2.36.0-source-release.zip (with props) Modified: dev/beam/2.36.0/apache-beam-2.36.0-source-release.zip.asc dev/beam/2.36.0/apache-beam-2.36.0-source-release.zip.sha512 Added: dev/beam/2.36.0/apache-beam-2.36.0-source-release.zip == Binary file - no diff available. Propchange: dev/beam/2.36.0/apache-beam-2.36.0-source-release.zip -- svn:mime-type = application/octet-stream Modified: dev/beam/2.36.0/apache-beam-2.36.0-source-release.zip.asc == --- dev/beam/2.36.0/apache-beam-2.36.0-source-release.zip.asc (original) +++ dev/beam/2.36.0/apache-beam-2.36.0-source-release.zip.asc Fri Feb 4 05:07:24 2022 @@ -1,16 +1,16 @@ -BEGIN PGP SIGNATURE- -iQIzBAABCgAdFiEEcw1ejUyoEMHwHTBLYQs4qhvhFlYFAmH8Kx8ACgkQYQs4qhvh -FlZU8Q/8CnaYxHJnW7OUMuC+wRQV13SuUaHnh12h2vy6+iI1OAv8z9fdige7t6LX -FWQJxbdHJKj5BuKNRGcuqUgdjkvtiYP21Uo4xZg5T+7QUMrRRCWRWfYhHkekyhPN -4vtYgmrQ0mShgqqMf9eCCGLLjWyBYj99q+JL4kyAXXR0dxYucXdGIpFBr7uqnmGZ -InhIFbKm8IBBjguBj9S7ms6bqHOSfPmNkqnX2wUWTl+MyM6MCv1TaoeiPXIPjXjA -BCQUCuDYljW48LvVz72uXhX2jSxL2gjqoyx825Aj2AXqbifsOiVTBuf6QIiL2UvO -CH1fHXt5I9B7g0Zq8VjJFQtmPgl3ItslzyoQWE6dH8SuFpSqzsbI/LqNfDeQvAtM -VeXw0JWT8gSH9bkgxsP6FlLjn8M02aFO3nSDNP8rfuDTkn03/rUWXx4x5Es2hRsK -TRISoZHb4XlUPC7CIXCa1DxknSDat1DHDIL/H5SCRyWtbt83eOxFwtd3Y0G7P9ur -ixM+7akm3hn9lczoDniCXwNuxkyHrQGFnESqbq8kG8uwi/jbzPZ81v+f6e2nbPxN -W3xxK60ze89nnBQ+YUfUavPsO8xk6ZgulLeSQ9S6eq0Yq01smF8hDgbkiD+iqIYY -srgFWsya+Qz0dfo/l3sUyDIns4qAfdIDSXXNAIelH+DkreCSdng= -=kERK +iQIzBAABCgAdFiEEcw1ejUyoEMHwHTBLYQs4qhvhFlYFAmH8sR4ACgkQYQs4qhvh +FlbAcQ//d6mxnbVd/rhjkEmx4vkImIP6u5ohouNvjsmi6/mo2DdsijDJCJVD9IVf +C1bMG5RCjMI9x137nZGz62uGH49dKLo9LXol6qHo79d3ClSPOw//It/9ADkZboVH +OQxI6fJAPOR6hLBnIrjY5yBC2zjNwvuAvBFqglCHbRvkPyI4sctOn0PglKbSoV8C +cVD24ylrjTQ2vhA+pzu219MPwQ9yeYVUwUQVZ1AoPyTpt4ZsalAvyBa+qtr0wAHY +c3ce16onBEYdtqHKhjSx2xcyC3Ri8UpPaMzVyyb81q0s7F3s36lDH5DuYb1gtWjo +Nx1ErNJZOUmAiOHMhskXyr+X5ZuhH/Mb0Nv24NBSnEat9Xmvb8ULUGJdLSQJ5O+V +qnQu+SpCnFxn4UycoQbrMpFwIHoDhumY+4GkxZ5GBC6AzqP/+hbV/ve8pF8bmUO3 +69N+U5sUcv9iMTe8DeDHPJsWkpXf760322Pd2AS48BO+HkZ2iHUlYAvtiGSI5Ong +FtgaTse2aZ8ic5f/BSF5SReT3soPe5fyM2GTEjP+bM3MsGRtDPS5rzoPQZKMlYP+ +OANcKiWNWD81utP0wJnXWRyiJcLrVtUqB3aaVDJwQIIuSIslruD2AiKQiEqWtEQD +iiU2Gyw8iLdMZ2O6ZXc8x6ETzd7R6kCj9+H9koYoiUI8hULp2/A= +=SaQh -END PGP SIGNATURE- Modified: dev/beam/2.36.0/apache-beam-2.36.0-source-release.zip.sha512 == --- dev/beam/2.36.0/apache-beam-2.36.0-source-release.zip.sha512 (original) +++ dev/beam/2.36.0/apache-beam-2.36.0-source-release.zip.sha512 Fri Feb 4 05:07:24 2022 @@ -1 +1 @@ -dc303474d4de58c6060bb9e7b5845f920b2ef5fa0aa5b8ede87a2a61f2eaca8713f2000bc69d71c41ae620116b301268d738a0d1a595a0bfc0c08c9cc0fd9311 apache-beam-2.36.0-source-release.zip +aeef8b680b22a0e6aa515d7b1dbd38623bd2c1402d92587d5c59c961e22ba3c4a7ccad7db539a01900c0e53a7c7dfbf86d44e6b79a5ddc43e653f8345ca97fe3 apache-beam-2.36.0-source-release.zip
[beam] branch master updated: Remove Python SQL Test example from catalog
This is an automated email from the ASF dual-hosted git repository. pabloem pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git The following commit(s) were added to refs/heads/master by this push: new 5f15d27 Remove Python SQL Test example from catalog new 724e689 Merge pull request #16713 from [BEAM-13815] [Playground] [Bugfix] Remove Python SQL Test example from catalog 5f15d27 is described below commit 5f15d2719cfd54c573876b6c462cb1c3fe8836d8 Author: Pavel Avilov AuthorDate: Thu Feb 3 14:03:21 2022 +0300 Remove Python SQL Test example from catalog --- sdks/python/apache_beam/transforms/sql_test.py | 9 - 1 file changed, 9 deletions(-) diff --git a/sdks/python/apache_beam/transforms/sql_test.py b/sdks/python/apache_beam/transforms/sql_test.py index 099b52b..854aec0 100644 --- a/sdks/python/apache_beam/transforms/sql_test.py +++ b/sdks/python/apache_beam/transforms/sql_test.py @@ -19,15 +19,6 @@ # pytype: skip-file -# beam-playground: -# name: SQLTest -# description: Unit-test for the transforms that use -# the SQL Expansion service. -# multifile: false -# context_line: 45 -# categories: -# - Beam SQL - import logging import typing import unittest
[beam] branch master updated (724e689 -> fda0b00)
This is an automated email from the ASF dual-hosted git repository.
pabloem pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 724e689 Merge pull request #16713 from [BEAM-13815] [Playground]
[Bugfix] Remove Python SQL Test example from catalog
add fda0b00 Merge pull request #16605 from [BEAM-13634][Playground]
Create a separate Dockerfile for the routing service
No new revisions were added by this update.
Summary of changes:
.github/workflows/build_playground_backend.yml | 24 ---
.github/workflows/build_playground_frontend.yml| 5 ++--
playground/backend/README.md | 2 +-
playground/backend/containers/java/build.gradle| 2 +-
playground/backend/containers/java/settings.gradle | 2 +-
.../backend/containers/{go => router}/Dockerfile | 27 ++
.../backend/containers/{go => router}/build.gradle | 10 +---
.../backend/containers/router/entrypoint.sh| 6 ++---
.../containers/{scio => router}/settings.gradle| 2 +-
playground/infrastructure/helm/values.yaml | 3 ++-
.../terraform/applications/backend-go/variables.tf | 2 +-
.../applications/backend-java/variables.tf | 2 +-
.../applications/backend-router/variables.tf | 2 +-
.../terraform/applications/frontend/variables.tf | 2 +-
settings.gradle.kts| 1 +
15 files changed, 45 insertions(+), 47 deletions(-)
copy playground/backend/containers/{go => router}/Dockerfile (77%)
copy playground/backend/containers/{go => router}/build.gradle (91%)
copy sdks/python/.coveragerc =>
playground/backend/containers/router/entrypoint.sh (93%)
mode change 100644 => 100755
copy playground/backend/containers/{scio => router}/settings.gradle (93%)
[beam] branch master updated (fda0b00 -> d8ab299)
This is an automated email from the ASF dual-hosted git repository. pabloem pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from fda0b00 Merge pull request #16605 from [BEAM-13634][Playground] Create a separate Dockerfile for the routing service add d8ab299 Merge pull request #16593 from [BEAM-13725][Playground] Add graph to the precompiled objects No new revisions were added by this update. Summary of changes: playground/api/v1/api.proto| 13 + playground/backend/cmd/server/controller.go| 12 + playground/backend/internal/api/v1/api.pb.go | 519 + playground/backend/internal/api/v1/api_grpc.pb.go | 38 ++ .../internal/cloud_bucket/precompiled_objects.go | 10 + playground/frontend/lib/api/v1/api.pb.dart | 94 playground/frontend/lib/api/v1/api.pbgrpc.dart | 31 ++ playground/frontend/lib/api/v1/api.pbjson.dart | 20 + playground/infrastructure/api/v1/api_pb2.py| 167 +-- playground/infrastructure/api/v1/api_pb2_grpc.py | 34 ++ 10 files changed, 713 insertions(+), 225 deletions(-)
[beam] branch master updated (d8ab299 -> 4b2343a)
This is an automated email from the ASF dual-hosted git repository. pabloem pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from d8ab299 Merge pull request #16593 from [BEAM-13725][Playground] Add graph to the precompiled objects add 4b2343a Merge pull request #16699 from [BEAM-13789][Playground] Change logic of keeping examples to the bucket on CD side No new revisions were added by this update. Summary of changes: playground/infrastructure/cd_helper.py | 21 ++- playground/infrastructure/ci_helper.py | 1 + playground/infrastructure/config.py | 18 + playground/infrastructure/grpc_client.py| 2 +- playground/infrastructure/helper.py | 12 ++- playground/infrastructure/test_cd_helper.py | 31 - playground/infrastructure/test_ci_helper.py | 7 +++ 7 files changed, 64 insertions(+), 28 deletions(-)
svn commit: r52392 - /dev/beam/2.36.0/python/
Author: emilyye Date: Fri Feb 4 06:53:26 2022 New Revision: 52392 Log: Staging Python artifacts for Apache Beam 2.36.0 RC3 Modified: dev/beam/2.36.0/python/apache-beam-2.36.0.zip dev/beam/2.36.0/python/apache-beam-2.36.0.zip.asc dev/beam/2.36.0/python/apache-beam-2.36.0.zip.sha512 dev/beam/2.36.0/python/apache_beam-2.36.0-cp36-cp36m-macosx_10_9_x86_64.whl dev/beam/2.36.0/python/apache_beam-2.36.0-cp36-cp36m-macosx_10_9_x86_64.whl.asc dev/beam/2.36.0/python/apache_beam-2.36.0-cp36-cp36m-macosx_10_9_x86_64.whl.sha512 dev/beam/2.36.0/python/apache_beam-2.36.0-cp36-cp36m-manylinux1_i686.whl dev/beam/2.36.0/python/apache_beam-2.36.0-cp36-cp36m-manylinux1_i686.whl.asc dev/beam/2.36.0/python/apache_beam-2.36.0-cp36-cp36m-manylinux1_i686.whl.sha512 dev/beam/2.36.0/python/apache_beam-2.36.0-cp36-cp36m-manylinux1_x86_64.whl dev/beam/2.36.0/python/apache_beam-2.36.0-cp36-cp36m-manylinux1_x86_64.whl.asc dev/beam/2.36.0/python/apache_beam-2.36.0-cp36-cp36m-manylinux1_x86_64.whl.sha512 dev/beam/2.36.0/python/apache_beam-2.36.0-cp36-cp36m-manylinux2010_i686.whl dev/beam/2.36.0/python/apache_beam-2.36.0-cp36-cp36m-manylinux2010_i686.whl.asc dev/beam/2.36.0/python/apache_beam-2.36.0-cp36-cp36m-manylinux2010_i686.whl.sha512 dev/beam/2.36.0/python/apache_beam-2.36.0-cp36-cp36m-manylinux2010_x86_64.whl dev/beam/2.36.0/python/apache_beam-2.36.0-cp36-cp36m-manylinux2010_x86_64.whl.asc dev/beam/2.36.0/python/apache_beam-2.36.0-cp36-cp36m-manylinux2010_x86_64.whl.sha512 dev/beam/2.36.0/python/apache_beam-2.36.0-cp36-cp36m-manylinux2014_aarch64.whl dev/beam/2.36.0/python/apache_beam-2.36.0-cp36-cp36m-manylinux2014_aarch64.whl.asc dev/beam/2.36.0/python/apache_beam-2.36.0-cp36-cp36m-manylinux2014_aarch64.whl.sha512 dev/beam/2.36.0/python/apache_beam-2.36.0-cp36-cp36m-win32.whl dev/beam/2.36.0/python/apache_beam-2.36.0-cp36-cp36m-win32.whl.asc dev/beam/2.36.0/python/apache_beam-2.36.0-cp36-cp36m-win32.whl.sha512 dev/beam/2.36.0/python/apache_beam-2.36.0-cp36-cp36m-win_amd64.whl dev/beam/2.36.0/python/apache_beam-2.36.0-cp36-cp36m-win_amd64.whl.asc dev/beam/2.36.0/python/apache_beam-2.36.0-cp36-cp36m-win_amd64.whl.sha512 dev/beam/2.36.0/python/apache_beam-2.36.0-cp37-cp37m-macosx_10_9_x86_64.whl dev/beam/2.36.0/python/apache_beam-2.36.0-cp37-cp37m-macosx_10_9_x86_64.whl.asc dev/beam/2.36.0/python/apache_beam-2.36.0-cp37-cp37m-macosx_10_9_x86_64.whl.sha512 dev/beam/2.36.0/python/apache_beam-2.36.0-cp37-cp37m-manylinux1_i686.whl dev/beam/2.36.0/python/apache_beam-2.36.0-cp37-cp37m-manylinux1_i686.whl.asc dev/beam/2.36.0/python/apache_beam-2.36.0-cp37-cp37m-manylinux1_i686.whl.sha512 dev/beam/2.36.0/python/apache_beam-2.36.0-cp37-cp37m-manylinux1_x86_64.whl dev/beam/2.36.0/python/apache_beam-2.36.0-cp37-cp37m-manylinux1_x86_64.whl.asc dev/beam/2.36.0/python/apache_beam-2.36.0-cp37-cp37m-manylinux1_x86_64.whl.sha512 dev/beam/2.36.0/python/apache_beam-2.36.0-cp37-cp37m-manylinux2010_i686.whl dev/beam/2.36.0/python/apache_beam-2.36.0-cp37-cp37m-manylinux2010_i686.whl.asc dev/beam/2.36.0/python/apache_beam-2.36.0-cp37-cp37m-manylinux2010_i686.whl.sha512 dev/beam/2.36.0/python/apache_beam-2.36.0-cp37-cp37m-manylinux2010_x86_64.whl dev/beam/2.36.0/python/apache_beam-2.36.0-cp37-cp37m-manylinux2010_x86_64.whl.asc dev/beam/2.36.0/python/apache_beam-2.36.0-cp37-cp37m-manylinux2010_x86_64.whl.sha512 dev/beam/2.36.0/python/apache_beam-2.36.0-cp37-cp37m-manylinux2014_aarch64.whl dev/beam/2.36.0/python/apache_beam-2.36.0-cp37-cp37m-manylinux2014_aarch64.whl.asc dev/beam/2.36.0/python/apache_beam-2.36.0-cp37-cp37m-manylinux2014_aarch64.whl.sha512 dev/beam/2.36.0/python/apache_beam-2.36.0-cp37-cp37m-win32.whl dev/beam/2.36.0/python/apache_beam-2.36.0-cp37-cp37m-win32.whl.asc dev/beam/2.36.0/python/apache_beam-2.36.0-cp37-cp37m-win32.whl.sha512 dev/beam/2.36.0/python/apache_beam-2.36.0-cp37-cp37m-win_amd64.whl dev/beam/2.36.0/python/apache_beam-2.36.0-cp37-cp37m-win_amd64.whl.asc dev/beam/2.36.0/python/apache_beam-2.36.0-cp37-cp37m-win_amd64.whl.sha512 dev/beam/2.36.0/python/apache_beam-2.36.0-cp38-cp38-macosx_10_9_x86_64.whl dev/beam/2.36.0/python/apache_beam-2.36.0-cp38-cp38-macosx_10_9_x86_64.whl.asc dev/beam/2.36.0/python/apache_beam-2.36.0-cp38-cp38-macosx_10_9_x86_64.whl.sha512 dev/beam/2.36.0/python/apache_beam-2.36.0-cp38-cp38-manylinux1_i686.whl dev/beam/2.36.0/python/apache_beam-2.36.0-cp38-cp38-manylinux1_i686.whl.asc dev/beam/2.36.0/python/apache_beam-2.36.0-cp38-cp38-manylinux1_i686.whl.sha512 dev/beam/2.36.0/python/apache_beam-2.36.0-cp38-cp38-manylinux1_x86_64.whl dev/beam/2.36.0/python/apache_beam-2.36.0-cp38-cp38-manylinux1_x86_64.whl.asc dev/beam/2.36.0/python/apache_beam-2.36.0-cp38-cp38-manylinux1_x86_64.whl.sha512 dev/beam/2.36.0/python/apache_beam-2.36.0-cp3
[beam] branch master updated (4b2343a -> aab61e9)
This is an automated email from the ASF dual-hosted git repository. timrobertson100 pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from 4b2343a Merge pull request #16699 from [BEAM-13789][Playground] Change logic of keeping examples to the bucket on CD side add fd7c496 Fixed CSS for Case study page add aab61e9 Merge pull request #16730: Fixed CSS for Case study page No new revisions were added by this update. Summary of changes: website/www/site/assets/scss/_case_study.scss | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-)
