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 51bd3a4 (commit)
to 23d0c47 (commit)
from 51bd3a4 [BEAM-10298] beam-linkage-check.sh should not swallow errors
(#12051)
add 354b97a [BEAM-9890] Try fixing BIT_AND(NULL) issue (#12110)
add 151d0b0 [BEAM-10270] Disable Pardo test with 200 iterations on Flink
(#12030)
add 35f5cb1 added missing markdown task summary for the introduction
section
add a8f3907 Merge pull request #12121 from [BEAM-10373] Add Missing
Markdown Documentation for Java Katas Introduction
add a60ad58 Move Dataflow runner to new beam-master-20200629 container
add e68a38b Merge #12135: Move Dataflow runner to new
beam-master-20200629 container
add 5d743ac [BEAM-9961] Fixes bug of missing projection application in
MongoDB IO (#12116)
add e7a3392 [BEAM-9615] Add bytes, bool, and iterable coders (#12127)
add 9cabeae [BEAM-10284] Add option to pass configuration into
ParquetIO.Sink
add 4fb27bc [BEAM-10284] Remove hadoop from ParquetIO.Sink public API
add fcafe3e Merge pull request #12064: [BEAM-10284] Add option to pass
configuration into ParquetIO.Sink
add 9ca80ae [BEAM-10381] Increase retries in pull_licenses_java.py from 3
to 9.
add 688ed5c Merge pull request #12130 from ajamato/master
add 5098152 [BEAM-10220] Add support for REQUIRE_MISSING in
RowJsonDeserializer, Make ACCEPT_MISSING_OR_NULL the default behavior. (#12035)
add 5e29b4f [BEAM-10312] Sub-element progress accounted for during
splitting.
add 8f2d49b Merge pull request #12124: [BEAM-10312] Sub-element progress
accounted for during splitting.
add 23d0c47 Remove misleading unsupported features mention for Python
streaming (#12140)
No new revisions were added by this update.
Summary of changes:
.../job_LoadTests_ParDo_Flink_Python.groovy | 48 ++--
CHANGES.md | 8 +-
.../Introduction/Hello Beam/Hello Beam/task.md | 0
runners/google-cloud-dataflow-java/build.gradle | 2 +-
.../dot/dot.go => core/graph/coder/bool.go} | 58 ++---
sdks/go/pkg/beam/core/graph/coder/bool_test.go | 79 +++++++
sdks/go/pkg/beam/core/graph/coder/bytes.go | 68 ++++++
sdks/go/pkg/beam/core/graph/coder/bytes_test.go | 61 +++++
sdks/go/pkg/beam/core/graph/coder/iterable.go | 122 ++++++++++
sdks/go/pkg/beam/core/graph/coder/iterable_test.go | 113 +++++++++
sdks/go/pkg/beam/core/runtime/exec/datasource.go | 138 +++++++----
.../pkg/beam/core/runtime/exec/datasource_test.go | 152 +++++++++++-
.../license_scripts/pull_licenses_java.py | 6 +-
.../java/org/apache/beam/sdk/util/RowJson.java | 83 +++++--
.../apache/beam/sdk/transforms/JsonToRowTest.java | 4 +-
.../java/org/apache/beam/sdk/util/RowJsonTest.java | 261 +++++++++++----------
.../impl/transform/BeamBuiltinAggregations.java | 133 ++++++++---
.../extensions/sql/BeamSqlDslAggregationTest.java | 180 +++++++++++---
.../provider/pubsub/PubsubMessageToRowTest.java | 6 +-
.../sql/zetasql/SqlStdOperatorMappingTable.java | 7 +-
.../sql/zetasql/ZetaSQLDialectSpecTest.java | 1 +
sdks/java/io/parquet/build.gradle | 1 +
.../org/apache/beam/sdk/io/parquet/ParquetIO.java | 30 ++-
sdks/python/apache_beam/io/mongodbio.py | 21 +-
sdks/python/apache_beam/io/mongodbio_test.py | 26 +-
.../en/documentation/sdks/python-streaming.md | 21 +-
26 files changed, 1268 insertions(+), 361 deletions(-)
copy learning/katas/{kotlin => java}/Introduction/Hello Beam/Hello
Beam/task.md (100%)
copy sdks/go/pkg/beam/{runners/dot/dot.go => core/graph/coder/bool.go} (50%)
create mode 100644 sdks/go/pkg/beam/core/graph/coder/bool_test.go
create mode 100644 sdks/go/pkg/beam/core/graph/coder/bytes.go
create mode 100644 sdks/go/pkg/beam/core/graph/coder/bytes_test.go
create mode 100644 sdks/go/pkg/beam/core/graph/coder/iterable.go
create mode 100644 sdks/go/pkg/beam/core/graph/coder/iterable_test.go
