You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ro...@apache.org on 2022/06/23 00:36:11 UTC
[beam] branch master updated (bf2ac4119aa -> 52e1b3ff9e9)
This is an automated email from the ASF dual-hosted git repository.
robertwb pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
from bf2ac4119aa Fix FlatMap numpy array bug (#22006)
add 6a39f9bf611 Streaming-related runner fixes.
add 029c582b111 Improvements to auto-started services.
add 6fc10e0b490 Fix version, asserts for remote execution.
add 1874b60679c Add IO dependencies.
add dac8ef20e00 Add several cross-language IOs.
add 3e4fe2e1e5a Disable tests that require new release is required for out-of-the-box testing.
add da9bce6fc61 More strongly typed outputs.
new 52e1b3ff9e9 Merge pull request #21723 Add several IOs to the typescript SDK.
The 1 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/typescript/package-lock.json | 1012 +++++++++++++++++---
sdks/typescript/package.json | 2 +
.../typescript/src/apache_beam/coders/row_coder.ts | 24 +-
sdks/typescript/src/apache_beam/io/avroio.ts | 55 ++
sdks/typescript/src/apache_beam/io/bigqueryio.ts | 58 ++
sdks/typescript/src/apache_beam/io/kafka.ts | 124 +++
sdks/typescript/src/apache_beam/io/parquetio.ts | 69 ++
sdks/typescript/src/apache_beam/io/pubsub.ts | 134 +++
sdks/typescript/src/apache_beam/io/pubsublite.ts | 55 ++
sdks/typescript/src/apache_beam/io/schemaio.ts | 65 ++
sdks/typescript/src/apache_beam/io/textio.ts | 129 ++-
.../src/apache_beam/runners/artifacts.ts | 6 +-
.../typescript/src/apache_beam/runners/dataflow.ts | 8 +-
.../apache_beam/runners/portable_runner/runner.ts | 32 +-
sdks/typescript/src/apache_beam/runners/runner.ts | 14 +-
.../src/apache_beam/runners/universal.ts | 4 +-
sdks/typescript/src/apache_beam/testing/assert.ts | 12 +-
.../src/apache_beam/transforms/flatten.ts | 1 -
.../src/apache_beam/transforms/python.ts | 59 ++
sdks/typescript/src/apache_beam/utils/service.ts | 152 ++-
.../typescript/src/apache_beam/utils/utils.ts | 21 +-
sdks/typescript/src/apache_beam/version.ts | 5 +-
sdks/typescript/src/apache_beam/worker/data.ts | 2 +-
sdks/typescript/src/apache_beam/worker/worker.ts | 3 +-
.../src/apache_beam/worker/worker_main.ts | 2 +
sdks/typescript/test/io_test.ts | 333 +++++++
26 files changed, 2199 insertions(+), 182 deletions(-)
create mode 100644 sdks/typescript/src/apache_beam/io/avroio.ts
create mode 100644 sdks/typescript/src/apache_beam/io/bigqueryio.ts
create mode 100644 sdks/typescript/src/apache_beam/io/kafka.ts
create mode 100644 sdks/typescript/src/apache_beam/io/parquetio.ts
create mode 100644 sdks/typescript/src/apache_beam/io/pubsub.ts
create mode 100644 sdks/typescript/src/apache_beam/io/pubsublite.ts
create mode 100644 sdks/typescript/src/apache_beam/io/schemaio.ts
create mode 100644 sdks/typescript/src/apache_beam/transforms/python.ts
copy playground/frontend/lib/modules/examples/models/outputs_model.dart => sdks/typescript/src/apache_beam/utils/utils.ts (68%)
create mode 100644 sdks/typescript/test/io_test.ts
[beam] 01/01: Merge pull request #21723 Add several IOs to the typescript SDK.
Posted by ro...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
robertwb pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit 52e1b3ff9e9b1c5067b59bbb8053f0bc53f9679f
Merge: bf2ac4119aa da9bce6fc61
Author: Robert Bradshaw <ro...@gmail.com>
AuthorDate: Wed Jun 22 17:36:03 2022 -0700
Merge pull request #21723 Add several IOs to the typescript SDK.
sdks/typescript/package-lock.json | 1012 +++++++++++++++++---
sdks/typescript/package.json | 2 +
.../typescript/src/apache_beam/coders/row_coder.ts | 24 +-
sdks/typescript/src/apache_beam/io/avroio.ts | 55 ++
sdks/typescript/src/apache_beam/io/bigqueryio.ts | 58 ++
sdks/typescript/src/apache_beam/io/kafka.ts | 124 +++
sdks/typescript/src/apache_beam/io/parquetio.ts | 69 ++
sdks/typescript/src/apache_beam/io/pubsub.ts | 134 +++
sdks/typescript/src/apache_beam/io/pubsublite.ts | 55 ++
sdks/typescript/src/apache_beam/io/schemaio.ts | 65 ++
sdks/typescript/src/apache_beam/io/textio.ts | 129 ++-
.../src/apache_beam/runners/artifacts.ts | 6 +-
.../typescript/src/apache_beam/runners/dataflow.ts | 8 +-
.../apache_beam/runners/portable_runner/runner.ts | 32 +-
sdks/typescript/src/apache_beam/runners/runner.ts | 14 +-
.../src/apache_beam/runners/universal.ts | 4 +-
sdks/typescript/src/apache_beam/testing/assert.ts | 12 +-
.../src/apache_beam/transforms/flatten.ts | 1 -
.../src/apache_beam/transforms/python.ts | 59 ++
sdks/typescript/src/apache_beam/utils/service.ts | 152 ++-
.../src/apache_beam/{version.ts => utils/utils.ts} | 16 +-
sdks/typescript/src/apache_beam/version.ts | 5 +-
sdks/typescript/src/apache_beam/worker/data.ts | 2 +-
sdks/typescript/src/apache_beam/worker/worker.ts | 3 +-
.../src/apache_beam/worker/worker_main.ts | 2 +
sdks/typescript/test/io_test.ts | 333 +++++++
26 files changed, 2201 insertions(+), 175 deletions(-)