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/04 02:48:07 UTC
[beam] tag nightly-master updated (d971ba1 -> d5a6c2f)
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