You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by gi...@apache.org on 2022/08/25 04:48:24 UTC
[beam] branch nightly-refs/heads/master updated (0474afbe608 -> 42b1640a25d)
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 0474afbe608 Merge pull request #22830 from kileys/fixdates
add d8063600b09 added link to setup instructions in WordCount example (#22832)
add 3f5ddbcf9fe Bump google.golang.org/api from 0.93.0 to 0.94.0 in /sdks (#22839)
add d6c0774b04f Bump cloud.google.com/go/bigquery from 1.38.0 to 1.39.0 in /sdks (#22837)
add 702ce768f7b Add an integration test for bag state (#22827)
add 80ced0fe216 Fix a few linting issues (#22842)
add 4d97ab61753 Updates old releases to use archive.apache.org
add 4d19439380b Merge pull request #22835: Updates old releases to use archive.apache.org
add ee06385c1a9 Add combining state support (#22826)
add 11e5b5a0fc2 Bump cloud.google.com/go/pubsub from 1.24.0 to 1.25.1 in /sdks (#22850)
add 63653aec39d Bump google.golang.org/grpc from 1.48.0 to 1.49.0 in /sdks (#22838)
add 0c6bb800dca [Website] update videos section (#22772)
add d47438a2977 Update Dataflow fnapi_container-version (#22852)
add ddfb6907288 Go SDK Katas: Update beam module dependency (#22753)
add 42b1640a25d unskip sklearn IT test (#22825)
No new revisions were added by this update.
Summary of changes:
build.gradle.kts | 2 +
.../aggregation/count/cmd/main.go | 8 +-
.../aggregation/count/pkg/task/task.go | 4 +-
.../aggregation/count/task-info.yaml | 21 +-
.../aggregation/count/test/task_test.go | 6 +-
.../common_transforms/aggregation/max/cmd/main.go | 8 +-
.../aggregation/max/pkg/task/task.go | 4 +-
.../aggregation/max/task-info.yaml | 21 +-
.../aggregation/max/test/task_test.go | 6 +-
.../common_transforms/aggregation/mean/cmd/main.go | 8 +-
.../aggregation/mean/pkg/task/task.go | 4 +-
.../aggregation/mean/task-info.yaml | 21 +-
.../aggregation/mean/test/task_test.go | 6 +-
.../common_transforms/aggregation/min/cmd/main.go | 8 +-
.../aggregation/min/pkg/task/task.go | 4 +-
.../aggregation/min/task-info.yaml | 21 +-
.../aggregation/min/test/task_test.go | 6 +-
.../common_transforms/aggregation/sum/cmd/main.go | 8 +-
.../aggregation/sum/pkg/task/task.go | 4 +-
.../aggregation/sum/task-info.yaml | 21 +-
.../aggregation/sum/test/task_test.go | 6 +-
.../go/common_transforms/filter/filter/cmd/main.go | 8 +-
.../filter/filter/pkg/task/task.go | 4 +-
.../common_transforms/filter/filter/task-info.yaml | 21 +-
.../filter/filter/test/task_test.go | 6 +-
.../go/common_transforms/filter/pardo/cmd/main.go | 8 +-
.../filter/pardo/pkg/task/task.go | 2 +-
.../common_transforms/filter/pardo/task-info.yaml | 21 +-
.../filter/pardo/test/task_test.go | 6 +-
.../additional_outputs/cmd/main.go | 8 +-
.../additional_outputs/pkg/task/task.go | 2 +-
.../additional_outputs/task-info.yaml | 21 +-
.../additional_outputs/test/task_test.go | 6 +-
.../branching/branching/cmd/main.go | 8 +-
.../branching/branching/pkg/task/task.go | 2 +-
.../branching/branching/task-info.yaml | 29 +-
.../branching/branching/test/task_test.go | 6 +-
.../cogroupbykey/cogroupbykey/cmd/main.go | 8 +-
.../cogroupbykey/cogroupbykey/pkg/task/task.go | 2 +-
.../cogroupbykey/cogroupbykey/task-info.yaml | 21 +-
.../cogroupbykey/cogroupbykey/test/task_test.go | 6 +-
.../combine/combine_perkey/cmd/main.go | 8 +-
.../combine/combine_perkey/pkg/task/task.go | 2 +-
.../combine/combine_perkey/task-info.yaml | 21 +-
.../combine/combine_perkey/test/task_test.go | 4 +-
.../core_transforms/combine/combinefn/cmd/main.go | 8 +-
.../combine/combinefn/pkg/task/task.go | 2 +-
.../combine/combinefn/task-info.yaml | 29 +-
.../combine/combinefn/test/task_test.go | 6 +-
.../combine/simple_function/cmd/main.go | 8 +-
.../combine/simple_function/pkg/task/task.go | 2 +-
.../combine/simple_function/task-info.yaml | 21 +-
.../combine/simple_function/test/task_test.go | 6 +-
.../composite/composite/cmd/main.go | 8 +-
.../composite/composite/pkg/common/common.go | 2 +-
.../composite/composite/pkg/task/task.go | 4 +-
.../composite/composite/task-info.yaml | 31 +-
.../composite/composite/test/task_test.go | 4 +-
.../go/core_transforms/flatten/flatten/cmd/main.go | 8 +-
.../flatten/flatten/pkg/task/task.go | 2 +-
.../core_transforms/flatten/flatten/task-info.yaml | 21 +-
.../flatten/flatten/test/task_test.go | 6 +-
.../groupbykey/groupbykey/cmd/main.go | 8 +-
.../groupbykey/groupbykey/pkg/task/task.go | 2 +-
.../groupbykey/groupbykey/task-info.yaml | 21 +-
.../groupbykey/groupbykey/test/task_test.go | 4 +-
.../katas/go/core_transforms/map/pardo/cmd/main.go | 8 +-
.../go/core_transforms/map/pardo/pkg/task/task.go | 2 +-
.../go/core_transforms/map/pardo/task-info.yaml | 23 +-
.../go/core_transforms/map/pardo/test/task_test.go | 6 +-
.../map/pardo_onetomany/cmd/main.go | 8 +-
.../map/pardo_onetomany/pkg/task/task.go | 2 +-
.../map/pardo_onetomany/task-info.yaml | 23 +-
.../map/pardo_onetomany/test/task_test.go | 6 +-
.../core_transforms/map/pardo_struct/cmd/main.go | 8 +-
.../map/pardo_struct/pkg/task/task.go | 2 +-
.../map/pardo_struct/task-info.yaml | 25 +-
.../map/pardo_struct/test/task_test.go | 6 +-
.../partition/partition/cmd/main.go | 8 +-
.../partition/partition/pkg/task/task.go | 2 +-
.../partition/partition/task-info.yaml | 21 +-
.../partition/partition/test/task_test.go | 6 +-
.../side_input/side_input/cmd/main.go | 8 +-
.../side_input/side_input/pkg/task/task.go | 2 +-
.../side_input/side_input/task-info.yaml | 25 +-
.../side_input/side_input/test/task_test.go | 6 +-
learning/katas/go/course-info.yaml | 21 +-
learning/katas/go/go.mod | 15 +-
learning/katas/go/go.sum | 1071 +++++++++++++++++++-
.../introduction/hello_beam/hello_beam/cmd/main.go | 10 +-
.../hello_beam/hello_beam/pkg/task/task.go | 2 +-
.../hello_beam/hello_beam/task-info.yaml | 25 +-
.../hello_beam/hello_beam/test/task_test.go | 10 +-
.../hello_beam/hello_beam_test/pkg/task/task.go | 2 +-
.../hello_beam/hello_beam_test/task-info.yaml | 23 +-
.../hello_beam/hello_beam_test/test/task_test.go | 8 +-
learning/katas/go/io/textio/read/cmd/main.go | 8 +-
learning/katas/go/io/textio/read/pkg/task/task.go | 4 +-
learning/katas/go/io/textio/read/task-info.yaml | 23 +-
learning/katas/go/io/textio/read/test/task_test.go | 10 +-
.../windowing/adding_timestamp/pardo/cmd/main.go | 6 +-
.../adding_timestamp/pardo/pkg/common/data.go | 2 +-
.../adding_timestamp/pardo/pkg/task/task.go | 4 +-
.../adding_timestamp/pardo/task-info.yaml | 21 +-
.../adding_timestamp/pardo/test/task_test.go | 6 +-
.../fixed_time_window/cmd/main.go | 8 +-
.../fixed_time_window/pkg/common/input.go | 4 +-
.../fixed_time_window/pkg/task/task.go | 7 +-
.../fixed_time_window/task-info.yaml | 27 +-
.../fixed_time_window/test/task_test.go | 6 +-
runners/google-cloud-dataflow-java/build.gradle | 2 +-
sdks/go.mod | 14 +-
sdks/go.sum | 27 +-
sdks/go/pkg/beam/core/graph/fn.go | 4 +-
sdks/go/pkg/beam/core/graph/fn_test.go | 11 +
sdks/go/pkg/beam/core/runtime/exec/translate.go | 20 +-
sdks/go/pkg/beam/core/runtime/exec/userstate.go | 93 +-
.../pkg/beam/core/runtime/exec/userstate_test.go | 4 +-
sdks/go/pkg/beam/core/runtime/graphx/translate.go | 36 +-
sdks/go/pkg/beam/core/state/state.go | 181 +++-
sdks/go/pkg/beam/core/state/state_test.go | 224 +++-
sdks/go/test/integration/integration.go | 3 +
sdks/go/test/integration/primitives/state.go | 57 +-
sdks/go/test/integration/primitives/state_test.go | 5 +
.../ml/inference/sklearn_inference_it_test.py | 1 -
.../documentation/resources/videos-and-podcasts.md | 5 +
.../www/site/content/en/get-started/downloads.md | 12 +-
.../content/en/get-started/wordcount-example.md | 4 +
128 files changed, 1927 insertions(+), 926 deletions(-)