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 ea1f292e9cf Update release-guide.md
add b086b96b05a [BEAM-14428] change text, change styling of connectors and
contribute tables
add 212d63d291b Merge pull request #17572: [BEAM-14428] I/O, community,
and contribute pages improvements
add 61cd0dfa1ec fixed typos in README.md
add 44274aef15b Merge pull request #17714 fixed typos in README.md
add 6e5ca0c0fa4 Update the PTransform and associated APIs to be less
class-based. (#17699)
add 47d8bce7e17 Vortex performance improvement: Enable multiple stream
clients per worker (#17550)
add 4689462a1c8 [BEAM-14488] Alias async flags. (#17711)
add de497f7766d [BEAM-14487] Make drain & update terminal states. (#17710)
add 5f61e152c41 Corrects I/O connectors availability status in Beam
Website.
add e9cfd8e4410 Merge pull request #17707: Corrects I/O connectors
availability status in Beam Website
add f1980dc917c [BEAM-14484] Improve behavior surrounding primary roots in
self-checkpointing (#17716)
add f3041e07864 Improve validation error message (#17719)
No new revisions were added by this update.
Summary of changes:
README.md | 4 +-
sdks/go/pkg/beam/core/graph/fn.go | 2 +-
sdks/go/pkg/beam/core/runtime/exec/datasource.go | 43 +++-
.../pkg/beam/core/runtime/exec/datasource_test.go | 69 ++++++
sdks/go/pkg/beam/core/runtime/graphx/translate.go | 1 +
sdks/go/pkg/beam/core/sdf/sdf.go | 4 +
.../{continuation_test.go => wrappedbounded.go} | 31 ++-
sdks/go/pkg/beam/runners/dataflow/dataflow.go | 7 +-
.../pkg/beam/runners/dataflow/dataflowlib/job.go | 49 ++--
.../beam/runners/dataflow/dataflowlib/job_test.go | 37 +++
.../test/integration/primitives/checkpointing.go | 16 +-
.../beam/sdk/io/gcp/bigquery/BigQueryOptions.java | 18 +-
.../StorageApiWriteRecordsInconsistent.java | 5 +-
.../bigquery/StorageApiWriteUnshardedRecords.java | 100 ++++++---
sdks/typescript/README.md | 6 +
sdks/typescript/src/apache_beam/coders/coders.ts | 28 ++-
.../src/apache_beam/examples/wordcount.ts | 19 +-
.../src/apache_beam/examples/wordcount_sql.ts | 10 +-
.../src/apache_beam/examples/wordcount_textio.ts | 19 +-
.../src/apache_beam/internal/pipeline.ts | 36 ++-
sdks/typescript/src/apache_beam/internal/urns.ts | 1 -
sdks/typescript/src/apache_beam/io/textio.ts | 22 +-
sdks/typescript/src/apache_beam/pvalue.ts | 104 +++++----
.../src/apache_beam/runners/direct_runner.ts | 12 +-
sdks/typescript/src/apache_beam/testing/assert.ts | 53 ++---
.../src/apache_beam/transforms/create.ts | 29 +--
.../src/apache_beam/transforms/external.ts | 23 +-
.../src/apache_beam/transforms/flatten.ts | 26 ++-
.../apache_beam/transforms/group_and_combine.ts | 161 +++++++------
.../typescript/src/apache_beam/transforms/index.ts | 2 +-
.../src/apache_beam/transforms/internal.ts | 150 +++++++------
.../typescript/src/apache_beam/transforms/pardo.ts | 245 +++++++++-----------
sdks/typescript/src/apache_beam/transforms/sql.ts | 35 ++-
.../src/apache_beam/transforms/transform.ts | 30 ++-
.../src/apache_beam/transforms/window.ts | 186 +++++++--------
.../src/apache_beam/transforms/windowings.ts | 135 +++++------
.../typescript/src/apache_beam/worker/operators.ts | 78 +++----
sdks/typescript/test/combine_test.ts | 56 +++--
sdks/typescript/test/primitives_test.ts | 88 +++-----
sdks/typescript/test/standard_coders_test.ts | 24 +-
sdks/typescript/test/wordcount.ts | 28 +--
website/www/site/assets/scss/_connectors.sass | 6 +
website/www/site/assets/scss/_contribute.sass | 52 +++++
website/www/site/content/en/contribute/_index.md | 17 +-
.../site/content/en/documentation/io/connectors.md | 249 +++++++++++----------
.../partials/section-menu/en/community.html | 10 +-
.../partials/section-menu/en/contribute.html | 6 +-
47 files changed, 1254 insertions(+), 1078 deletions(-)
copy sdks/go/pkg/beam/core/sdf/{continuation_test.go => wrappedbounded.go}
(55%)
