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/08/11 02:49:17 UTC
[beam] tag nightly-master updated (de8ff70 -> 3e7371e)
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 de8ff70 (commit)
to 3e7371e (commit)
from de8ff70 Merge pull request #12487 from ettirapp/gcs-test-fix - Fixing Typos in GCS and S3 Filesystem Tests
add 8ab92d7 [BEAM-10361] upgrade Kotlin version in example (#12497)
add 2fa9189 BEAM-10668 - Replace toLowerCase().equals() with equalsIgnoreCase
add 10ccde9 Merge pull request #12512: [BEAM-10668] Replace toLowerCase().equals() with equalsIgnoreCase
add efc31dd [BEAM-10471] change the test condition for testEstimatedSizeBytes to greater than 0 to ensure that the dataset is a least split.
add 939d6f3 Merge pull request #12510 from echauchot/BEAM-10471-testEstimatedSize-condition
add b1f11a9 Move value conversion logic out of ExpressionConverter
add 79d69f4 Simplify ZetaSqlBeamTranslationUtils
add af1ce64 Merge pull request #12507 from robinyqiu/refactor
add e44c3c2 [BEAM-9891] Added ZetaSQL planner support and uploaded 100G data (#12502)
add 3e7371e [BEAM-10300] Improve JdbcIOTest.testFluentBackOffConfiguration stability (#12517)
No new revisions were added by this update.
Summary of changes:
examples/kotlin/build.gradle | 2 +-
.../examples/kotlin/cookbook/BigQueryTornadoes.kt | 1 -
.../provider/datacatalog/BigQueryTableFactory.java | 2 +-
.../provider/datacatalog/PubsubTableFactory.java | 2 +-
.../extensions/sql/zetasql/BeamZetaSqlCalcRel.java | 11 +-
.../sdk/extensions/sql/zetasql/DateTimeUtils.java | 47 --
.../sdk/extensions/sql/zetasql/SqlAnalyzer.java | 6 +-
.../sql/zetasql/ZetaSqlBeamTranslationUtils.java | 230 +++----
.../zetasql/ZetaSqlCalciteTranslationUtils.java | 339 ++++++++---
.../translation/AggregateScanConverter.java | 6 +-
.../zetasql/translation/ExpressionConverter.java | 317 +---------
.../sql/zetasql/translation/SqlOperators.java | 4 +-
.../zetasql/ZetaSqlBeamTranslationUtilsTest.java | 10 +-
.../beam/sdk/io/cassandra/CassandraIOTest.java | 6 +-
.../org/apache/beam/sdk/io/jdbc/JdbcIOTest.java | 69 +--
sdks/java/testing/tpcds/build.gradle | 1 +
.../{BeamTpcds.java => BeamSqlEnvRunner.java} | 64 +-
.../java/org/apache/beam/sdk/tpcds/BeamTpcds.java | 114 +---
.../java/org/apache/beam/sdk/tpcds/CsvToRow.java | 58 ++
.../java/org/apache/beam/sdk/tpcds/RowToCsv.java | 52 ++
.../apache/beam/sdk/tpcds/SqlTransformRunner.java | 138 +++++
.../beam/sdk/tpcds/TpcdsParametersReader.java | 3 +-
.../org/apache/beam/sdk/tpcds/TpcdsSchemas.java | 672 +++++++++++++++++++++
.../tpcds/src/main/resources/queries/query96.sql | 9 +-
.../apache/beam/sdk/tpcds/TpcdsSchemasTest.java | 124 ++++
25 files changed, 1522 insertions(+), 765 deletions(-)
copy sdks/java/testing/tpcds/src/main/java/org/apache/beam/sdk/tpcds/{BeamTpcds.java => BeamSqlEnvRunner.java} (71%)
create mode 100644 sdks/java/testing/tpcds/src/main/java/org/apache/beam/sdk/tpcds/CsvToRow.java
create mode 100644 sdks/java/testing/tpcds/src/main/java/org/apache/beam/sdk/tpcds/RowToCsv.java
create mode 100644 sdks/java/testing/tpcds/src/main/java/org/apache/beam/sdk/tpcds/SqlTransformRunner.java
create mode 100644 sdks/java/testing/tpcds/src/main/java/org/apache/beam/sdk/tpcds/TpcdsSchemas.java
create mode 100644 sdks/java/testing/tpcds/src/test/java/org/apache/beam/sdk/tpcds/TpcdsSchemasTest.java