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 4a94c51 (commit)
to 63629c0 (commit)
from 4a94c51 Merge pull request #13126 More flexible dataframe conversions.
add 5e76e66 Unset variables from failed assignments.
add 30b003d Track line numbers in test parsing.
add 392213a Better parsing of multi-line examples.
add bd1a2a9 Strip ipython prompts.
add 46c226e Merge pull request #13077 [BEAM-9561] Dataframe test
infrastructure improvements.
add 376d2a6 [BEAM-10893] Add Json support to Kafka Table Provider (#12839)
add 70a3b89 [INFRA-20858] Update JDK name to match Jenkins.
add 319d3ff Merge pull request #13213: [INFRA-20858] Update JDK name to
match Jenkins.
add 578d6f6 Add max buffering duration for GroupIntoBatches in Python SDK
add 5620419 Merge pull request #13144 from [BEAM-10475] Add max buffering
duration option for GroupIntoBatches transform in Python
add 63629c0 [BEAM-7372][BEAM-8371][BEAM-9372] drop python 2.7 and 3.5
support from python container (#13193)
No new revisions were added by this update.
Summary of changes:
.test-infra/jenkins/CommonJobProperties.groovy | 2 +-
CHANGES.md | 1 +
...mKafkaCSVTable.java => BeamKafkaJsonTable.java} | 62 +++++-----
.../meta/provider/kafka/KafkaTableProvider.java | 5 +-
...bleCSVTest.java => BeamKafkaTableJsonTest.java} | 45 +++++--
...derCSVIT.java => KafkaTableProviderJsonIT.java} | 16 +--
sdks/python/apache_beam/dataframe/doctests.py | 36 ++++--
sdks/python/apache_beam/dataframe/doctests_test.py | 28 ++++-
.../apache_beam/runners/direct/direct_runner.py | 7 ++
sdks/python/apache_beam/transforms/util.py | 76 ++++++++----
sdks/python/apache_beam/transforms/util_test.py | 132 +++++++++++++++------
sdks/python/container/boot.go | 4 +-
.../dsls/sql/extensions/create-external-table.md | 14 ++-
13 files changed, 293 insertions(+), 135 deletions(-)
copy
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/kafka/{BeamKafkaCSVTable.java
=> BeamKafkaJsonTable.java} (60%)
copy
sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/meta/provider/kafka/{BeamKafkaTableCSVTest.java
=> BeamKafkaTableJsonTest.java} (51%)
copy
sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/meta/provider/kafka/{KafkaTableProviderCSVIT.java
=> KafkaTableProviderJsonIT.java} (72%)
