You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by gi...@apache.org on 2020/12/23 03:30:35 UTC
[beam] tag nightly-master updated (0350f2e -> c2e07fb)
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 0350f2e (commit)
to c2e07fb (commit)
from 0350f2e Merge pull request #13584 from ibzib/BEAM-9637
add 926c649 Fix typo in join explanation
add 44f198d Merge pull request #13577: Fix typo in join explanation
add 8a9a259 Fix regex in Kotlin MinimalWordCount example. (#13570)
add 6171a36 [BEAM-11456] Fix flaky table provider tests (Kafka and Pubsub) (#13542)
add c2e07fb [BEAM-10925] Convert ScalarFn to Method. (#13593)
No new revisions were added by this update.
Summary of changes:
.../beam/examples/kotlin/MinimalWordCount.kt | 2 +-
sdks/java/extensions/sql/build.gradle | 13 +-
.../sdk/extensions/sql/impl/ScalarFnReflector.java | 73 ++++++
.../extensions/sql/impl/ScalarFnReflectorTest.java | 141 +++++++++++
.../provider/kafka/KafkaTableProviderAvroIT.java | 39 ---
.../provider/kafka/KafkaTableProviderCSVIT.java | 42 ----
.../meta/provider/kafka/KafkaTableProviderIT.java | 169 +++++++++++--
.../provider/kafka/KafkaTableProviderJsonIT.java | 40 ---
.../provider/kafka/KafkaTableProviderProtoIT.java | 53 ----
.../sql/meta/provider/pubsub/PubsubAvroIT.java | 102 --------
.../sql/meta/provider/pubsub/PubsubJsonIT.java | 76 ------
.../provider/pubsub/PubsubTableProviderIT.java | 273 ++++++++++++++++-----
.../content/en/documentation/programming-guide.md | 2 +-
13 files changed, 572 insertions(+), 453 deletions(-)
create mode 100644 sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/ScalarFnReflector.java
create mode 100644 sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/impl/ScalarFnReflectorTest.java
delete mode 100644 sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/meta/provider/kafka/KafkaTableProviderAvroIT.java
delete mode 100644 sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/meta/provider/kafka/KafkaTableProviderCSVIT.java
delete mode 100644 sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/meta/provider/kafka/KafkaTableProviderJsonIT.java
delete mode 100644 sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/meta/provider/kafka/KafkaTableProviderProtoIT.java
delete mode 100644 sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/meta/provider/pubsub/PubsubAvroIT.java
delete mode 100644 sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/meta/provider/pubsub/PubsubJsonIT.java