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 40326dd (commit)
to 06dbe4f (commit)
from 40326dd Merge pull request #14851 from udim/beam-12352
add c097d84 Fix Kafka expansion issues introduced by PR14801
add 2ad332b Merge pull request #14849 from [BEAM-10670] Fix Kafka
expansion issues introduced by PR14801
add 37f8495 [BEAM-11851] Allow config map to be passed to Confluent
Schema Registry client (#14840)
add d10e66f Add Python Dataflow V2 test to jobs list.
add b169788 Merge pull request #14862 from ibzib/py-dfv2
add 6bfbe31 [BEAM-12339] Implement CREATE FUNCTION statement in Calcite
dialect.
add 52f8987 [BEAM-12339] Move unparse tests to different class to avoid
'pipeline not run' error.
add 775e75f Merge pull request #14828 from ibzib/BEAM-12339
add 61f0b34 [BEAM-12246] Fix ib.collect(dataframe) indexing (#14778)
add a3c744e Graph java 8 and 11 metrics separately (#14860)
add 904a39e [BEAM-10670] Update Twister2Runner.runTest with the same
logic as Twister2Runner.run
add 06dbe4f Merge pull request #14864 from boyuanzz/fix
No new revisions were added by this update.
Summary of changes:
.test-infra/jenkins/README.md | 1 +
.../Nexmark_Dataflow_RunnerV2.json | 30 ++++-
CHANGES.md | 1 +
.../apache/beam/runners/direct/DirectRunner.java | 10 --
.../org/apache/beam/runners/flink/FlinkRunner.java | 7 --
.../org/apache/beam/runners/samza/SamzaRunner.java | 12 +-
.../SparkStructuredStreamingRunner.java | 13 +--
.../org/apache/beam/runners/spark/SparkRunner.java | 9 +-
.../beam/runners/spark/SparkRunnerDebugger.java | 9 +-
.../beam/runners/twister2/Twister2Runner.java | 19 +---
.../extensions/sql/src/main/codegen/config.fmpp | 6 +
.../sql/src/main/codegen/includes/parserImpls.ftl | 30 +++++
.../sql/impl/LazyAggregateCombineFn.java | 51 +++++++++
.../extensions/sql/impl/ScalarFunctionImpl.java | 14 ++-
.../beam/sdk/extensions/sql/impl/UdafImpl.java | 46 ++++----
.../sql/impl/parser/SqlCreateFunction.java | 122 +++++++++++++++++++++
.../sql/impl/LazyAggregateCombineFnTest.java | 78 +++++++++++++
.../extensions/sql/impl/parser/BeamDDLTest.java | 36 ++++++
.../sql/impl/parser/SqlCreateFunctionTest.java | 73 ++++++++++++
...onfluentSchemaRegistryDeserializerProvider.java | 14 ++-
.../java/org/apache/beam/sdk/io/kafka/KafkaIO.java | 39 ++++++-
.../runners/interactive/interactive_beam.py | 21 +++-
.../runners/interactive/interactive_runner_test.py | 119 +++++++++++++++++++-
.../interactive/options/capture_limiters.py | 10 +-
.../interactive/options/capture_limiters_test.py | 16 +++
.../runners/interactive/recording_manager.py | 10 +-
.../apache_beam/runners/interactive/utils.py | 10 +-
.../apache_beam/runners/interactive/utils_test.py | 61 ++++++++---
28 files changed, 750 insertions(+), 117 deletions(-)
create mode 100644
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/parser/SqlCreateFunction.java
create mode 100644
sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/impl/parser/SqlCreateFunctionTest.java
