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 e7f2589 (commit)
to 56048f2 (commit)
from e7f2589 Merge pull request #12243 from
kennknowles/SparkPortableExecutionTest
add 130046b Enhance Combine transform for nullability analysis
add 3f68f26 [BEAM-10502] Enable checker in zetasketch extension
add d957ce4 Merge pull request #12272: [BEAM-10502] Enable checker in
zetasketch extension
add 3b9aae2 Cleanup some old pipeline examples. (#12248)
add 593fa88 Merge pull request #12074 from [BEAM-10313] Add
without_defaults to built-in Combiners in Python
add 1389531 Port PipelineOptionsFactory from Guava Function to
java.lang.function.Function
add 8a44663 Inline trivial methods with overly strict types from
ReflectHelpers
add d42abd3 Inline trivial fields with overly-specific types in
PipelineOptionsFactory
add 9b73f66 Convert static Function fields on ReflectHelpers to static
methods
add bc64d08 Improve nullability in PipelineOptionsFactory
add 4725d96 Merge pull request #12271: [BEAM-10496] Improve nullability
analysis for :sdks:java:core
add 152fb08 [BEAM-10506]: Flake / failure in SplunkEventWriterTesTest
add de1c147 Merge pull request #12279: [BEAM-10506]: Fix Flake / failure
in SplunkEventWriterTest
add 5eeb633 Loosen Nexmark streaming pipeline finish condition
add 3d9d66e Merge pull request #12281 from y1chi/nexmark_count
add 0affb8f [BEAM-XXXX] Add note on zetaSQL dependencies
add ccb4fc4 Update overview.md
add a46f007 Merge pull request #12254 from jaketf/docs/zetaSQLDeps: Add
note on zetaSQL dependencies
add 56048f2 Move Java function implementations to a sub-module (#12247)
No new revisions were added by this update.
Summary of changes:
.../beam/sdk/options/PipelineOptionsFactory.java | 185 ++++++++++----------
.../beam/sdk/options/PipelineOptionsValidator.java | 2 +-
.../org/apache/beam/sdk/transforms/Combine.java | 7 +-
.../sdk/transforms/reflect/DoFnSignatures.java | 6 +-
.../beam/sdk/util/common/ReflectHelpers.java | 189 +++++++++------------
.../beam/sdk/util/common/ReflectHelpersTest.java | 60 +++----
.../sdk/extensions/sql/zetasql/SqlAnalyzer.java | 3 +-
....java => SupportedZetaSqlBuiltinFunctions.java} | 106 ++----------
.../sdk/extensions/sql/zetasql/ZetaSqlIdUtils.java | 84 ---------
.../translation/AggregateScanConverter.java | 1 -
.../zetasql/translation/ExpressionConverter.java | 8 +-
.../SqlCaseWithValueOperatorRewriter.java | 4 +-
.../SqlCoalesceOperatorRewriter.java | 4 +-
.../SqlIfNullOperatorRewriter.java | 4 +-
.../SqlNullIfOperatorRewriter.java | 4 +-
.../{ => translation}/SqlOperatorRewriter.java | 4 +-
.../zetasql/{ => translation}/SqlOperators.java | 14 +-
.../translation/SqlStdOperatorMappingTable.java | 104 ++++++++++++
.../{ => translation}/SqlWindowTableFunction.java | 4 +-
.../{ => translation/impl}/BeamBuiltinMethods.java | 2 +-
.../{ => translation/impl}/DateFunctions.java | 3 +-
.../{ => translation/impl}/StringFunctions.java | 2 +-
.../{ => translation/impl}/TimestampFunctions.java | 3 +-
.../zetasql/translation/impl}/package-info.java | 8 +-
.../sql/zetasql/ZetaSqlDialectSpecTest.java | 2 +-
.../sql/zetasql/ZetaSqlTimeFunctionsTest.java | 1 -
sdks/java/extensions/zetasketch/build.gradle | 2 +-
.../beam/sdk/extensions/zetasketch/HllCount.java | 8 +-
.../zetasketch/HllCountMergePartialFn.java | 24 +--
.../BigQueryHllSketchCompatibilityIT.java | 14 +-
.../beam/sdk/io/splunk/SplunkEventWriterTest.java | 8 +
.../apache/beam/sdk/io/splunk/SplunkIOTest.java | 8 +
.../apache/beam/sdk/nexmark/NexmarkLauncher.java | 2 +-
.../examples/cookbook/bigtableio_it_test.py | 23 ++-
.../examples/cookbook/combiners_test.py | 24 +--
sdks/python/apache_beam/pipeline.py | 3 +-
sdks/python/apache_beam/transforms/combiners.py | 117 +++++++++----
.../apache_beam/transforms/combiners_test.py | 79 ++++++++-
sdks/python/scripts/generate_pydoc.sh | 1 +
.../content/en/documentation/dsls/sql/overview.md | 8 +-
40 files changed, 582 insertions(+), 553 deletions(-)
rename
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/{SqlStdOperatorMappingTable.java
=> SupportedZetaSqlBuiltinFunctions.java} (88%)
delete mode 100644
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/ZetaSqlIdUtils.java
rename
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/{
=> translation}/SqlCaseWithValueOperatorRewriter.java (95%)
rename
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/{
=> translation}/SqlCoalesceOperatorRewriter.java (95%)
rename
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/{
=> translation}/SqlIfNullOperatorRewriter.java (94%)
rename
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/{
=> translation}/SqlNullIfOperatorRewriter.java (94%)
rename
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/{
=> translation}/SqlOperatorRewriter.java (93%)
rename
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/{
=> translation}/SqlOperators.java (94%)
create mode 100644
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/SqlStdOperatorMappingTable.java
rename
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/{
=> translation}/SqlWindowTableFunction.java (97%)
rename
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/{
=> translation/impl}/BeamBuiltinMethods.java (97%)
rename
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/{
=> translation/impl}/DateFunctions.java (91%)
rename
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/{
=> translation/impl}/StringFunctions.java (98%)
rename
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/{
=> translation/impl}/TimestampFunctions.java (93%)
copy
sdks/java/extensions/sql/{datacatalog/src/main/java/org/apache/beam/sdk/extensions/sql/example
=>
zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/impl}/package-info.java
(80%)
