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%)
