beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From github-...@apache.org
Subject [beam] tag nightly-master updated (37fd13e -> a60aeba)
Date Sat, 03 Jul 2021 03:20:00 GMT
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 37fd13e  (commit)
      to a60aeba  (commit)
    from 37fd13e  [BEAM-12422] Drop other optional logger libraries since Netty can detect
which logger is available automatically
     add 6770621  Expose ReadAllFromTFRecord as public in tfrecordio
     add fc254b1  Merge pull request #15114 from ajothomas/ExposeReadAllFromTFRecord
     add d0ed701  [BEAM-10937] Tour of Beam Windowing notebook (#14962)
     add 74d4e2f  [BEAM-12456] Add reading jdbc by partitions
     add 796fb9a  Merge pull request #15049: [BEAM-12456] Parallel querying in JdbcIO
     add a232b9d  Fix generator send_type / return_type warning.
     add 9c24ba6  Merge pull request #15061: [BEAM-8473] Fix generator send_type / return_type
warning
     add b76db4d  [BEAM-12513] Update initial sections of BPG for Go (#15057)
     add 05f9e77  Merge pull request #14980 from [BEAM-12468] added bigquery specific project
id property
     add 48ad919  [BEAM-11994] Add HarnessMonitoringInfosRequest/Response InstructionRequest
and MonitoringInfosMetadataRequest/Response support to Java SDK.
     add a60aeba  Merge pull request #14805 from [BEAM-11994] Add HarnessMonitoringInfosRequest/Response
InstructionRequest and MonitoringInfosMetadataRequest/Response support to Java SDK.

No new revisions were added by this update.

Summary of changes:
 CHANGES.md                                         |   1 +
 .../tour-of-beam/reading-and-writing-data.ipynb    |  74 +--
 examples/notebooks/tour-of-beam/windowing.ipynb    | 703 +++++++++++++++++++++
 .../runners/core/construction/Environments.java    |   1 +
 .../runners/core/metrics/MetricsContainerImpl.java |  26 +-
 .../core/metrics/MetricsContainerImplTest.java     |  10 +
 sdks/go/examples/snippets/01_03intro.go            | 102 +++
 sdks/go/examples/snippets/04transforms.go          | 289 +++++++++
 sdks/go/examples/snippets/04transforms_test.go     | 185 ++++++
 .../runtime/coderx => examples/snippets}/doc.go    |  15 +-
 .../apache/beam/sdk/metrics/MetricsContainer.java  |   6 +
 .../java/org/apache/beam/fn/harness/FnHarness.java |  11 +
 .../HarnessMonitoringInfosInstructionHandler.java  |  54 ++
 ...rnessMonitoringInfosInstructionHandlerTest.java |  66 ++
 .../beam/sdk/io/gcp/bigquery/BigQueryIO.java       |  28 +-
 .../beam/sdk/io/gcp/bigquery/BigQueryOptions.java  |   5 +
 .../sdk/io/gcp/bigquery/BigQueryQueryHelper.java   |  16 +-
 .../io/gcp/bigquery/BigQueryQuerySourceDef.java    |   4 +-
 .../io/gcp/bigquery/BigQueryStorageSourceBase.java |   6 +-
 .../gcp/bigquery/BigQueryStorageTableSource.java   |   5 +-
 .../io/gcp/bigquery/BigQueryTableSourceDef.java    |   5 +-
 .../gcp/bigquery/DynamicDestinationsHelpers.java   |   5 +-
 .../beam/sdk/io/gcp/bigquery/TestBigQuery.java     |  17 +-
 .../beam/sdk/io/gcp/bigquery/WriteTables.java      |   6 +-
 .../sdk/io/gcp/bigquery/BigQueryIOReadTest.java    | 125 ++--
 .../gcp/bigquery/BigQueryIOStorageQueryTest.java   |  77 +++
 .../io/gcp/bigquery/BigQueryIOStorageReadTest.java |  24 +
 .../sdk/io/gcp/bigquery/BigQueryIOWriteTest.java   |  18 +-
 .../beam/sdk/io/gcp/bigquery/ProjectOverride.java} |  17 +-
 .../java/org/apache/beam/sdk/io/jdbc/JdbcIO.java   | 245 +++++++
 .../java/org/apache/beam/sdk/io/jdbc/JdbcUtil.java |  78 +++
 .../org/apache/beam/sdk/io/jdbc/JdbcIOTest.java    |  88 +++
 sdks/python/apache_beam/io/tfrecordio.py           |   2 +-
 sdks/python/apache_beam/typehints/typehints.py     |   4 +-
 .../content/en/documentation/programming-guide.md  | 432 +++++++++++--
 .../site/content/en/get-started/tour-of-beam.md    |   7 +
 36 files changed, 2545 insertions(+), 212 deletions(-)
 create mode 100644 examples/notebooks/tour-of-beam/windowing.ipynb
 create mode 100644 sdks/go/examples/snippets/01_03intro.go
 create mode 100644 sdks/go/examples/snippets/04transforms.go
 create mode 100644 sdks/go/examples/snippets/04transforms_test.go
 copy sdks/go/{pkg/beam/core/runtime/coderx => examples/snippets}/doc.go (65%)
 create mode 100644 sdks/java/harness/src/main/java/org/apache/beam/fn/harness/control/HarnessMonitoringInfosInstructionHandler.java
 create mode 100644 sdks/java/harness/src/test/java/org/apache/beam/fn/harness/control/HarnessMonitoringInfosInstructionHandlerTest.java
 copy sdks/java/{extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/udf/UDF.java
=> io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/ProjectOverride.java}
(74%)

Mime
View raw message