beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From github-...@apache.org
Subject [beam] tag nightly-master updated (d971ba1 -> d5a6c2f)
Date Tue, 04 Aug 2020 02:48:07 GMT
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 d971ba1  (commit)
      to d5a6c2f  (commit)
    from d971ba1  Widen ranges for GCP libraries (#12198)
     add 539f6c4  [BEAM-10602] Use python_streaming_pardo_5 table for latency results
     add 2f47b82  Merge pull request #12451: [BEAM-10602] Use python_streaming_pardo_5 table
for latency results
     add a5eab74  [BEAM-10471] issue a JMX call to cassandra StorageServiceMbeam.refreshSizeEstimates
after insertion to update the cassandra internal size estimates to have consistent results
in CassandraIOTest.testEstimatedSizeBytes
     add e3ea99b  [BEAM-10471] fix a wrong comment
     add cbd9aa2  Merge pull request #12432 from echauchot/BEAM-10471-force-refresh-size-estimates
     add 879abe3  Update Python Katas on Stepik based on the latest pipeline "with" style
     add 5e71256  Merge pull request #12447 from henryken/with-katas-stepik
     add de81742  [BEAM-10599] Add documentation about CI on GitHub Action (#12405)
     add 54fe9f6  Fix link for S3FileSystem (#12450)
     add 4e56953  [BEAM-9543] built the basis for Match_Recog
     add 72232fc  [BEAM-9543] built the basis for Match_Recog
     add 064ada7  [BEAM-9543] implemented `partition by`
     add 9cd1a82  [BEAM-9543] implemented `order by`
     add c07b8a8  [BEAM-9543] fixed `order by` coder issue
     add cdb7e9f  [BEAM-9543] fixed `order by` coder issue
     add cc63e55  [BEAM-9543] applied regex pattern match
     add b2b189d  [BEAM-9543] applied regex pattern match
     add 08abbab  [BEAM-9543] fixed sortKey serialization problem
     add 03a33c6  [BEAM-9543] fixed sortKey serialization problem
     add ec7c929  [BEAM-9543] fixed serialization problem
     add f52d96f  [BEAM-9543] recognized simple pattern
     add 8d6ffcc  [BEAM-9543] recognized simple pattern
     add a7d111f  [BEAM-9543] fixed code style
     add f529b87  [BEAM-9543] supported regex quantifier
     add 0bf24db  [BEAM-9543] added javadoc
     add 422cbe2  [BEAM-9543] removed CEPTypeName.java
     add adc2354  [BEAM-9543] added Measures implementation (unfinished)
     add ebc41a2  [BEAM-9543] added Measures implementation
     add 8793574  [BEAM-9543] added Measures implementation
     add 040d1f4  [BEAM-9543] fixed minor issues
     add 799491b  [BEAM-9543] fixed minor style issues
     add 5833667  Merge pull request #12232 from Mark-Zeng/BEAM-9543-patternRecog
     add d24a3ca  [BEAM-7390] Add max code snippets (#12409)
     add a33d4cf  [BEAM-7390] Add min code snippets
     add 30ee7cb1 Merge pull request #12457 from davidcavazos/min-docs
     add d09c56f  [BEAM-7390] Add mean code snippets (#12437)
     add c154af8  [BEAM-9839] OnTimerContext should not create a new one when processing each
element/timer in FnApiDoFnRunner (#12391)
     add 05e5c72  Fix dictionary changes size error in pickler.py (#12458)
     add c2369bd  [BEAM-9891] TPC-DS module initialization, tables and queries stored (#12436)
     add 59b3383  Interactive: clean up when pipeline is out of scope (#12339)
     add 8d8cd30  Fixed pcoll visualization in datatable
     add 13c77a8  Merge pull request #12442 from Fixed pcoll visualization in datatable
     add b87bb64  Merge pull request #12331 [BEAM-10601] DICOM API Beam IO connector
     add 9900674  Refactor SplittableParDoExpander.
     add 46729bc  Address comments.
     add ab05adf  Fix SDF/Process input id.
     add fa3ca2b  Merge pull request #12371 from boyuanzz/refactor
     add 29ea00e  [BEAM-10631] Fix performance of Schema#indexOf (#12456)
     add 00d16aa  [BEAM-10499] Adds a descriptive toString to SamzaRunner KeyedTimerData
     add d5a6c2f  Merge pull request #12304 from Borzoo/beam-10499-nicer-tostring

No new revisions were added by this update.

Summary of changes:
 .github/PULL_REQUEST_TEMPLATE.md                   |   7 +
 .github/workflows/build_wheels.yml                 |  11 +-
 .../perftests_metrics/ParDo_Load_Tests.json        |   2 +-
 CHANGES.md                                         |   1 +
 CI.md                                              | 104 ++++
 README.md                                          |   1 +
 .../Aggregation/Count/task-remote-info.yaml        |   2 +-
 .../Aggregation/Largest/task-remote-info.yaml      |   2 +-
 .../Aggregation/Mean/task-remote-info.yaml         |   2 +-
 .../Aggregation/Smallest/task-remote-info.yaml     |   2 +-
 .../Aggregation/Sum/task-remote-info.yaml          |   2 +-
 .../Filter/Filter/task-remote-info.yaml            |   2 +-
 .../Filter/ParDo/task-remote-info.yaml             |   2 +-
 .../WithKeys/WithKeys/task-remote-info.yaml        |   2 +-
 .../Branching/Branching/task-remote-info.yaml      |   2 +-
 .../CoGroupByKey/task-remote-info.yaml             |   2 +-
 .../Combine/Combine PerKey/task-remote-info.yaml   |   2 +-
 .../Combine/CombineFn/task-remote-info.yaml        |   2 +-
 .../Combine/Simple Function/task-remote-info.yaml  |   2 +-
 .../Composite Transform/task-remote-info.yaml      |   2 +-
 .../Flatten/Flatten/task-remote-info.yaml          |   2 +-
 .../GroupByKey/GroupByKey/task-remote-info.yaml    |   2 +-
 .../Map/FlatMap/task-remote-info.yaml              |   2 +-
 .../Core Transforms/Map/Map/task-remote-info.yaml  |   2 +-
 .../Map/ParDo OneToMany/task-remote-info.yaml      |   2 +-
 .../Map/ParDo/task-remote-info.yaml                |   2 +-
 .../Partition/Partition/task-remote-info.yaml      |   2 +-
 .../Side Input/Side Input/task-remote-info.yaml    |   2 +-
 .../Side Output/Side Output/task-remote-info.yaml  |   2 +-
 .../Word Count/Word Count/task-remote-info.yaml    |   2 +-
 .../Built-in IOs/task-remote-info.yaml             |   2 +-
 .../IO/TextIO/ReadFromText/task-remote-info.yaml   |   2 +-
 .../Hello Beam/Hello Beam/task-remote-info.yaml    |   2 +-
 .../Adding Timestamp/ParDo/task-remote-info.yaml   |   2 +-
 .../Fixed Time Window/task-remote-info.yaml        |   2 +-
 learning/katas/python/course-remote-info.yaml      |   2 +-
 .../graph/SplittableParDoExpander.java             | 301 +++--------
 .../beam/runners/samza/runtime/KeyedTimerData.java |  12 +
 .../java/org/apache/beam/sdk/schemas/Schema.java   |   4 +-
 .../org/apache/beam/sdk/schemas/SchemaTest.java    |  20 +
 .../beam/sdk/extensions/sql/impl/cep/CEPCall.java  |  83 +++
 .../sdk/extensions/sql/impl/cep/CEPFieldRef.java   |  52 ++
 .../beam/sdk/extensions/sql/impl/cep/CEPKind.java  |  39 ++
 .../sdk/extensions/sql/impl/cep/CEPLiteral.java    | 195 +++++++
 .../sdk/extensions/sql/impl/cep/CEPMeasure.java    |  57 ++
 .../sdk/extensions/sql/impl/cep/CEPOperation.java  |  48 ++
 .../sdk/extensions/sql/impl/cep/CEPOperator.java   |  65 +++
 .../sdk/extensions/sql/impl/cep/CEPPattern.java    | 172 ++++++
 .../beam/sdk/extensions/sql/impl/cep/CEPUtil.java  | 249 +++++++++
 .../beam/sdk/extensions/sql/impl/cep/OrderKey.java |  74 +++
 .../extensions/sql/impl/cep/PatternCondition.java  |  36 ++
 .../sdk/extensions/sql/impl/cep/Quantifier.java    |  46 ++
 .../sdk/extensions/sql/impl/cep/package-info.java  |  26 +
 .../extensions/sql/impl/planner/BeamRuleSets.java  |   4 +-
 .../sdk/extensions/sql/impl/rel/BeamMatchRel.java  | 529 +++++++++++++++++++
 .../extensions/sql/impl/rule/BeamMatchRule.java    |  57 ++
 .../extensions/sql/impl/schema/BeamTableUtils.java |   6 +
 .../extensions/sql/impl/rel/BeamMatchRelTest.java  | 264 ++++++++++
 .../apache/beam/fn/harness/FnApiDoFnRunner.java    |  11 +-
 .../beam/sdk/io/cassandra/CassandraIOTest.java     |   8 +-
 sdks/java/testing/tpcds/build.gradle               |  52 ++
 .../java/org/apache/beam/sdk/tpcds/BeamTpcds.java  | 129 +++++
 .../org/apache/beam/sdk/tpcds/QueryReader.java     |  59 +++
 .../beam/sdk/tpcds/TableSchemaJSONLoader.java      | 112 ++++
 .../org/apache/beam/sdk/tpcds/TpcdsOptions.java    |  42 ++
 .../beam/sdk/tpcds/TpcdsOptionsRegistrar.java      |  33 ++
 .../beam/sdk/tpcds/TpcdsParametersReader.java      | 108 ++++
 .../java/org/apache/beam/sdk/tpcds/TpcdsRun.java   |  40 ++
 .../tpcds/src/main/resources/queries/query1.sql    |  38 ++
 .../tpcds/src/main/resources/queries/query10.sql   |  72 +++
 .../tpcds/src/main/resources/queries/query11.sql   |  94 ++++
 .../tpcds/src/main/resources/queries/query12.sql   |  47 ++
 .../tpcds/src/main/resources/queries/query13.sql   |  64 +++
 .../tpcds/src/main/resources/queries/query14.sql   | 223 ++++++++
 .../tpcds/src/main/resources/queries/query15.sql   |  33 ++
 .../tpcds/src/main/resources/queries/query16.sql   |  44 ++
 .../tpcds/src/main/resources/queries/query17.sql   |  58 +++
 .../tpcds/src/main/resources/queries/query18.sql   |  47 ++
 .../tpcds/src/main/resources/queries/query19.sql   |  38 ++
 .../tpcds/src/main/resources/queries/query2.sql    |  73 +++
 .../tpcds/src/main/resources/queries/query20.sql   |  43 ++
 .../tpcds/src/main/resources/queries/query21.sql   |  43 ++
 .../tpcds/src/main/resources/queries/query22.sql   |  33 ++
 .../tpcds/src/main/resources/queries/query23.sql   | 120 +++++
 .../tpcds/src/main/resources/queries/query24.sql   | 119 +++++
 .../tpcds/src/main/resources/queries/query25.sql   |  61 +++
 .../tpcds/src/main/resources/queries/query26.sql   |  34 ++
 .../tpcds/src/main/resources/queries/query27.sql   |  36 ++
 .../tpcds/src/main/resources/queries/query28.sql   |  66 +++
 .../tpcds/src/main/resources/queries/query29.sql   |  60 +++
 .../tpcds/src/main/resources/queries/query3.sql    |  34 ++
 .../tpcds/src/main/resources/queries/query30.sql   |  44 ++
 .../tpcds/src/main/resources/queries/query31.sql   |  65 +++
 .../tpcds/src/main/resources/queries/query32.sql   |  41 ++
 .../tpcds/src/main/resources/queries/query33.sql   |  88 ++++
 .../tpcds/src/main/resources/queries/query34.sql   |  44 ++
 .../tpcds/src/main/resources/queries/query35.sql   |  71 +++
 .../tpcds/src/main/resources/queries/query36.sql   |  43 ++
 .../tpcds/src/main/resources/queries/query37.sql   |  30 ++
 .../tpcds/src/main/resources/queries/query38.sql   |  36 ++
 .../tpcds/src/main/resources/queries/query39.sql   |  66 +++
 .../tpcds/src/main/resources/queries/query4.sql    | 129 +++++
 .../tpcds/src/main/resources/queries/query40.sql   |  41 ++
 .../tpcds/src/main/resources/queries/query41.sql   |  65 +++
 .../tpcds/src/main/resources/queries/query42.sql   |  35 ++
 .../tpcds/src/main/resources/queries/query43.sql   |  32 ++
 .../tpcds/src/main/resources/queries/query44.sql   |  48 ++
 .../tpcds/src/main/resources/queries/query45.sql   |  33 ++
 .../tpcds/src/main/resources/queries/query46.sql   |  48 ++
 .../tpcds/src/main/resources/queries/query47.sql   |  64 +++
 .../tpcds/src/main/resources/queries/query48.sql   |  79 +++
 .../tpcds/src/main/resources/queries/query49.sql   | 142 +++++
 .../tpcds/src/main/resources/queries/query5.sql    | 141 +++++
 .../tpcds/src/main/resources/queries/query50.sql   |  72 +++
 .../tpcds/src/main/resources/queries/query51.sql   |  58 +++
 .../tpcds/src/main/resources/queries/query52.sql   |  35 ++
 .../tpcds/src/main/resources/queries/query53.sql   |  41 ++
 .../tpcds/src/main/resources/queries/query54.sql   |  69 +++
 .../tpcds/src/main/resources/queries/query55.sql   |  27 +
 .../tpcds/src/main/resources/queries/query56.sql   |  82 +++
 .../tpcds/src/main/resources/queries/query57.sql   |  61 +++
 .../tpcds/src/main/resources/queries/query58.sql   |  78 +++
 .../tpcds/src/main/resources/queries/query59.sql   |  57 ++
 .../tpcds/src/main/resources/queries/query6.sql    |  39 ++
 .../tpcds/src/main/resources/queries/query60.sql   |  91 ++++
 .../tpcds/src/main/resources/queries/query61.sql   |  57 ++
 .../tpcds/src/main/resources/queries/query62.sql   |  48 ++
 .../tpcds/src/main/resources/queries/query63.sql   |  42 ++
 .../tpcds/src/main/resources/queries/query64.sql   | 134 +++++
 .../tpcds/src/main/resources/queries/query65.sql   |  42 ++
 .../tpcds/src/main/resources/queries/query66.sql   | 233 +++++++++
 .../tpcds/src/main/resources/queries/query67.sql   |  57 ++
 .../tpcds/src/main/resources/queries/query68.sql   |  55 ++
 .../tpcds/src/main/resources/queries/query69.sql   |  60 +++
 .../tpcds/src/main/resources/queries/query7.sql    |  34 ++
 .../tpcds/src/main/resources/queries/query70.sql   |  51 ++
 .../tpcds/src/main/resources/queries/query71.sql   |  52 ++
 .../tpcds/src/main/resources/queries/query72.sql   |  42 ++
 .../tpcds/src/main/resources/queries/query73.sql   |  41 ++
 .../tpcds/src/main/resources/queries/query74.sql   |  74 +++
 .../tpcds/src/main/resources/queries/query75.sql   |  83 +++
 .../tpcds/src/main/resources/queries/query76.sql   |  37 ++
 .../tpcds/src/main/resources/queries/query77.sql   | 121 +++++
 .../tpcds/src/main/resources/queries/query78.sql   |  71 +++
 .../tpcds/src/main/resources/queries/query79.sql   |  36 ++
 .../tpcds/src/main/resources/queries/query8.sql    | 121 +++++
 .../tpcds/src/main/resources/queries/query80.sql   | 109 ++++
 .../tpcds/src/main/resources/queries/query81.sql   |  44 ++
 .../tpcds/src/main/resources/queries/query82.sql   |  30 ++
 .../tpcds/src/main/resources/queries/query83.sql   |  80 +++
 .../tpcds/src/main/resources/queries/query84.sql   |  34 ++
 .../tpcds/src/main/resources/queries/query85.sql   |  97 ++++
 .../tpcds/src/main/resources/queries/query86.sql   |  39 ++
 .../tpcds/src/main/resources/queries/query87.sql   |  35 ++
 .../tpcds/src/main/resources/queries/query88.sql   | 106 ++++
 .../tpcds/src/main/resources/queries/query89.sql   |  41 ++
 .../tpcds/src/main/resources/queries/query9.sql    |  63 +++
 .../tpcds/src/main/resources/queries/query90.sql   |  35 ++
 .../tpcds/src/main/resources/queries/query91.sql   |  44 ++
 .../tpcds/src/main/resources/queries/query92.sql   |  43 ++
 .../tpcds/src/main/resources/queries/query93.sql   |  31 ++
 .../tpcds/src/main/resources/queries/query94.sql   |  42 ++
 .../tpcds/src/main/resources/queries/query95.sql   |  45 ++
 .../tpcds/src/main/resources/queries/query96.sql   |  29 ++
 .../tpcds/src/main/resources/queries/query97.sql   |  38 ++
 .../tpcds/src/main/resources/queries/query98.sql   |  46 ++
 .../tpcds/src/main/resources/queries/query99.sql   |  48 ++
 .../src/main/resources/schemas/call_center.json    |  33 ++
 .../src/main/resources/schemas/catalog_page.json   |  11 +
 .../main/resources/schemas/catalog_returns.json    |  29 ++
 .../src/main/resources/schemas/catalog_sales.json  |  36 ++
 .../tpcds/src/main/resources/schemas/customer.json |  20 +
 .../main/resources/schemas/customer_address.json   |  15 +
 .../resources/schemas/customer_demographics.json   |  11 +
 .../tpcds/src/main/resources/schemas/date_dim.json |  30 ++
 .../resources/schemas/household_demographics.json  |   7 +
 .../src/main/resources/schemas/income_band.json    |   5 +
 .../src/main/resources/schemas/inventory.json      |   7 +
 .../tpcds/src/main/resources/schemas/item.json     |  24 +
 .../src/main/resources/schemas/promotion.json      |  21 +
 .../tpcds/src/main/resources/schemas/reason.json   |   5 +
 .../src/main/resources/schemas/ship_mode.json      |   8 +
 .../tpcds/src/main/resources/schemas/store.json    |  31 ++
 .../src/main/resources/schemas/store_returns.json  |  22 +
 .../src/main/resources/schemas/store_sales.json    |  25 +
 .../tpcds/src/main/resources/schemas/time_dim.json |  12 +
 .../src/main/resources/schemas/warehouse.json      |  16 +
 .../tpcds/src/main/resources/schemas/web_page.json |  16 +
 .../src/main/resources/schemas/web_returns.json    |  26 +
 .../src/main/resources/schemas/web_sales.json      |  36 ++
 .../tpcds/src/main/resources/schemas/web_site.json |  28 +
 .../org/apache/beam/sdk/tpcds/QueryReaderTest.java | 205 ++++++++
 .../beam/sdk/tpcds/TableSchemaJSONLoaderTest.java  | 151 ++++++
 .../beam/sdk/tpcds/TpcdsParametersReaderTest.java  |  92 ++++
 sdks/python/apache_beam/internal/pickler.py        |   7 +-
 sdks/python/apache_beam/io/gcp/dicomclient.py      | 128 +++++
 sdks/python/apache_beam/io/gcp/dicomio.py          | 579 +++++++++++++++++++++
 sdks/python/apache_beam/io/gcp/dicomio_test.py     | 468 +++++++++++++++++
 .../runners/interactive/background_caching_job.py  |   2 +-
 .../interactive/background_caching_job_test.py     |   4 +-
 .../interactive/display/pcoll_visualization.py     |  24 +-
 .../runners/interactive/interactive_environment.py |  78 ++-
 .../interactive/interactive_environment_test.py    |  27 +-
 .../messaging/interactive_environment_inspector.py |  17 +
 .../runners/interactive/options/capture_control.py |  11 +-
 sdks/python/setup.py                               |   1 +
 settings.gradle                                    |   1 +
 .../transforms/python/aggregation/max.md           |  58 ++-
 .../transforms/python/aggregation/mean.md          |  65 ++-
 .../transforms/python/aggregation/min.md           |  58 ++-
 .../en/documentation/transforms/python/overview.md |   4 +-
 website/www/site/data/io_matrix.yaml               |   2 +-
 .../partials/section-menu/en/documentation.html    |   2 +
 213 files changed, 11385 insertions(+), 337 deletions(-)
 create mode 100644 CI.md
 create mode 100644 sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/cep/CEPCall.java
 create mode 100644 sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/cep/CEPFieldRef.java
 create mode 100644 sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/cep/CEPKind.java
 create mode 100644 sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/cep/CEPLiteral.java
 create mode 100644 sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/cep/CEPMeasure.java
 create mode 100644 sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/cep/CEPOperation.java
 create mode 100644 sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/cep/CEPOperator.java
 create mode 100644 sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/cep/CEPPattern.java
 create mode 100644 sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/cep/CEPUtil.java
 create mode 100644 sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/cep/OrderKey.java
 create mode 100644 sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/cep/PatternCondition.java
 create mode 100644 sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/cep/Quantifier.java
 create mode 100644 sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/cep/package-info.java
 create mode 100644 sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamMatchRel.java
 create mode 100644 sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rule/BeamMatchRule.java
 create mode 100644 sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamMatchRelTest.java
 create mode 100644 sdks/java/testing/tpcds/build.gradle
 create mode 100644 sdks/java/testing/tpcds/src/main/java/org/apache/beam/sdk/tpcds/BeamTpcds.java
 create mode 100644 sdks/java/testing/tpcds/src/main/java/org/apache/beam/sdk/tpcds/QueryReader.java
 create mode 100644 sdks/java/testing/tpcds/src/main/java/org/apache/beam/sdk/tpcds/TableSchemaJSONLoader.java
 create mode 100644 sdks/java/testing/tpcds/src/main/java/org/apache/beam/sdk/tpcds/TpcdsOptions.java
 create mode 100644 sdks/java/testing/tpcds/src/main/java/org/apache/beam/sdk/tpcds/TpcdsOptionsRegistrar.java
 create mode 100644 sdks/java/testing/tpcds/src/main/java/org/apache/beam/sdk/tpcds/TpcdsParametersReader.java
 create mode 100644 sdks/java/testing/tpcds/src/main/java/org/apache/beam/sdk/tpcds/TpcdsRun.java
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query1.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query10.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query11.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query12.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query13.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query14.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query15.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query16.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query17.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query18.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query19.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query2.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query20.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query21.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query22.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query23.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query24.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query25.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query26.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query27.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query28.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query29.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query3.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query30.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query31.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query32.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query33.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query34.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query35.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query36.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query37.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query38.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query39.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query4.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query40.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query41.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query42.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query43.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query44.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query45.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query46.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query47.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query48.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query49.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query5.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query50.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query51.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query52.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query53.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query54.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query55.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query56.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query57.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query58.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query59.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query6.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query60.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query61.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query62.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query63.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query64.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query65.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query66.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query67.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query68.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query69.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query7.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query70.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query71.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query72.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query73.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query74.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query75.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query76.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query77.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query78.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query79.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query8.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query80.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query81.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query82.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query83.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query84.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query85.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query86.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query87.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query88.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query89.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query9.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query90.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query91.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query92.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query93.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query94.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query95.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query96.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query97.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query98.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/queries/query99.sql
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/schemas/call_center.json
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/schemas/catalog_page.json
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/schemas/catalog_returns.json
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/schemas/catalog_sales.json
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/schemas/customer.json
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/schemas/customer_address.json
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/schemas/customer_demographics.json
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/schemas/date_dim.json
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/schemas/household_demographics.json
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/schemas/income_band.json
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/schemas/inventory.json
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/schemas/item.json
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/schemas/promotion.json
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/schemas/reason.json
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/schemas/ship_mode.json
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/schemas/store.json
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/schemas/store_returns.json
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/schemas/store_sales.json
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/schemas/time_dim.json
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/schemas/warehouse.json
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/schemas/web_page.json
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/schemas/web_returns.json
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/schemas/web_sales.json
 create mode 100644 sdks/java/testing/tpcds/src/main/resources/schemas/web_site.json
 create mode 100644 sdks/java/testing/tpcds/src/test/java/org/apache/beam/sdk/tpcds/QueryReaderTest.java
 create mode 100644 sdks/java/testing/tpcds/src/test/java/org/apache/beam/sdk/tpcds/TableSchemaJSONLoaderTest.java
 create mode 100644 sdks/java/testing/tpcds/src/test/java/org/apache/beam/sdk/tpcds/TpcdsParametersReaderTest.java
 create mode 100644 sdks/python/apache_beam/io/gcp/dicomclient.py
 create mode 100644 sdks/python/apache_beam/io/gcp/dicomio.py
 create mode 100644 sdks/python/apache_beam/io/gcp/dicomio_test.py


Mime
View raw message