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 2023/06/10 05:03:59 UTC
[beam] branch nightly-refs/heads/master updated (bfa7a63f47f -> 6ad2b12c099)
This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch nightly-refs/heads/master
in repository https://gitbox.apache.org/repos/asf/beam.git
from bfa7a63f47f Beam Quest Blogpost (#27004)
add 82bf983103c add runners theory for golang (#25251)
add bd074f04b56 Lint fixes: receiver consistency. (#27037)
add e1cc124b6a9 [Playground] Add KafkaStreaming example (#26890)
add 639dcf70b27 Pass reference instead of value to cmp.Diff (#27053)
add 3d7ced6e3d7 Always make runner v2 default and return legacy container tag when runner_v1 is disabled (#27052)
add 2a5ac112532 Disable kaniko cache compression when prebuilding images (#27023)
add e54edd8c283 Disable pip cache on the workers to reduce prebuilt container image size (#27035)
add 718a449bf89 Beam quest Blog Addon (#27051)
add 95ecb31452f Make use of prism in periodic tests not cross compile. (#27054)
add 14534fb3421 Move AdaptiveThrottler impl to new Components directory (#27018)
add c3b330c66c6 Merge pull request #27047: Enable pubsub dynamic destinations by default
add 26591a513d4 [Playground] Make new python examples runnable (#27028)
add 74bad1add9c reads all files from metadata list (#27059)
add ea729dfd7ed [Tour of Beam] Learning content for "Splittable DoFn" module (#25707)
add 97562d9d920 Unpin tox version in Beam code base (#26082)
add fb73142e28a Issue26858 tob tests examples (#26932)
add 4badaee0293 Fix direct SDF runner handle_process_outputs (#27062)
add 0eb4513d0ca [#27064] Make Tag existence explicit in release docs. (#27070)
add 2e4e68bc8f0 Add Certification + Beam Quest to Documentation (#26997)
add 8e5bf7c577d Add note for updated release tag for 2.48 (#27073)
add 3213394640e Quote Addition + Sharing instructions [Beam Quest Blog] (#27066)
add 6dde0a655c1 Update Playground examples (#25032)
add 9f79599c4f1 Update TensorRT dockerfile (#27072)
add e51ed1cd08a Option to return timezone aware datetime for to_utc_datetime (#26962)
add 497bf5b589e Update to libraries-bom 26.16.0 (#27074)
add f676a6479f0 [Tour of Beam] Learning content for "Cross-language Transforms" module (#26227)
add 1de37064e40 Bump google.golang.org/api from 0.125.0 to 0.126.0 in /sdks (#27081)
add e3df4c17136 Bigquery schema generation fix (#26960)
add d2754716b98 Github Workflow Replacement for Jenkins Job, beam_PreCommit_Go (Cron, Commit, Phrase) (#27042)
add e772c0bcd2e Preserve output when a pipeline dies on timeout (#26928) (#26929)
add 9f8e7c577b3 [Playground] [Frontend] FCE updated to v0.3.0, minor improvements (#27063)
add 10ee5fd3144 Embed examples (#26933)
add 57fff810426 [Playground] - New role add (#27082)
add 5898b708b0c Release Guide update for Playground environment (#27043)
add e351272a711 Update learning-resources.md with links to video material (#27079)
add 608b06759c7 Cut the Playground output if it is too long (#27083) (#27084)
add 6ad2b12c099 Refactor key coder for Samza portable runner (#27095)
No new revisions were added by this update.
Summary of changes:
.github/workflows/beam_PreCommit_Go.yml | 8 +
CHANGES.md | 3 +-
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 12 +-
examples/java/build.gradle | 2 +
.../apache/beam/examples/DebuggingWordCount.java | 2 +-
.../beam/examples/KafkaPassengerCountJson.java | 174 +
.../org/apache/beam/examples/KafkaStreaming.java | 320 +
.../apache/beam/examples/KafkaWordCountAvro.java | 39 +-
.../apache/beam/examples/KafkaWordCountJson.java | 38 +-
.../org/apache/beam/examples/MinimalWordCount.java | 2 +-
.../apache/beam/examples/WindowedWordCount.java | 2 +-
.../java/org/apache/beam/examples/WordCount.java | 2 +-
.../org/apache/beam/examples/complete/TfIdf.java | 2 +-
.../examples/complete/TopWikipediaSessions.java | 2 +-
.../beam/examples/complete/TrafficMaxLaneFlow.java | 2 +-
.../beam/examples/complete/TrafficRoutes.java | 2 +-
.../beam/examples/cookbook/DistinctExample.java | 2 +-
.../apache/beam/examples/complete/TfIdfTest.java | 13 -
.../beam/examples/complete/game/GameStatsTest.java | 13 -
.../examples/cookbook/DistinctExampleTest.java | 13 -
.../commontransforms/aggregation/count/Task.java | 2 +-
.../commontransforms/aggregation/max/Task.java | 2 +-
.../commontransforms/aggregation/mean/Task.java | 2 +-
.../commontransforms/aggregation/min/Task.java | 2 +-
.../commontransforms/aggregation/sum/Task.java | 2 +-
.../katas/commontransforms/filter/filter/Task.java | 2 +-
.../katas/commontransforms/filter/pardo/Task.java | 2 +-
.../katas/commontransforms/withkeys/Task.java | 4 +-
.../katas/coretransforms/branching/Task.java | 4 +-
.../katas/coretransforms/cogroupbykey/Task.java | 2 +-
.../combine/binarycombinefnlambda/Task.java | 4 +-
.../combine/binarycombinefn/Task.java | 4 +-
.../coretransforms/combine/combineperkey/Task.java | 2 +-
.../coretransforms/combine/combinefn/Task.java | 2 +-
.../katas/coretransforms/combine/simple/Task.java | 2 +-
.../katas/coretransforms/composite/Task.java | 2 +-
.../katas/coretransforms/flatten/Task.java | 4 +-
.../katas/coretransforms/groupbykey/Task.java | 4 +-
.../katas/coretransforms/map/mapelements/Task.java | 4 +-
.../coretransforms/map/pardoonetomany/Task.java | 4 +-
.../katas/coretransforms/map/pardo/Task.java | 4 +-
.../katas/coretransforms/partition/Task.java | 4 +-
.../katas/coretransforms/sideinput/Task.java | 20 +-
.../katas/coretransforms/sideoutput/Task.java | 4 +-
.../learning/katas/examples/wordcount/Task.java | 4 +-
.../beam/learning/katas/intro/hello/Task.java | 6 +-
.../katas/triggers/earlytriggers/Task.java | 2 +-
.../katas/triggers/eventtimetriggers/Task.java | 2 +-
.../katas/triggers/windowaccummode/Task.java | 2 +-
.../windowing/addingtimestamp/pardo/Task.java | 4 +-
.../addingtimestamp/withtimestamps/Task.java | 4 +-
.../learning/katas/windowing/fixedwindow/Task.java | 2 +-
.../Common Transforms/Aggregation/Count/task.py | 2 +-
.../Common Transforms/Aggregation/Largest/task.py | 2 +-
.../Common Transforms/Aggregation/Mean/task.py | 2 +-
.../Common Transforms/Aggregation/Smallest/task.py | 2 +-
.../Common Transforms/Aggregation/Sum/task.py | 2 +-
.../python/Common Transforms/Filter/Filter/task.py | 2 +-
.../python/Common Transforms/Filter/ParDo/task.py | 2 +-
.../Common Transforms/WithKeys/WithKeys/task.py | 2 +-
.../Core Transforms/Branching/Branching/task.py | 2 +-
.../CoGroupByKey/CoGroupByKey/task.py | 2 +-
.../Core Transforms/Combine/Combine PerKey/task.py | 2 +-
.../Core Transforms/Combine/CombineFn/task.py | 4 +-
.../Combine/Simple Function/task.py | 2 +-
.../Composite Transform/task.py | 2 +-
.../python/Core Transforms/Flatten/Flatten/task.py | 2 +-
.../Core Transforms/GroupByKey/GroupByKey/task.py | 2 +-
.../python/Core Transforms/Map/FlatMap/task.py | 2 +-
.../katas/python/Core Transforms/Map/Map/task.py | 2 +-
.../Core Transforms/Map/ParDo OneToMany/task.py | 4 +-
.../katas/python/Core Transforms/Map/ParDo/task.py | 4 +-
.../Core Transforms/Partition/Partition/task.py | 2 +-
.../Core Transforms/Side Input/Side Input/task.py | 4 +-
.../Side Output/Side Output/task.py | 4 +-
.../python/Examples/Word Count/Word Count/task.py | 6 +-
.../katas/python/IO/TextIO/ReadFromText/task.py | 2 +-
.../Introduction/Hello Beam/Hello Beam/task.py | 3 +-
.../Streaming/Timestamps/Add Timestamps/task.py | 2 +-
.../Streaming/Triggers/Early Triggers/task.py | 2 +-
.../Streaming/Triggers/Event Time Triggers/task.py | 2 +-
.../Triggers/Window Accumulation Modes/task.py | 2 +-
.../python/Streaming/Windows/Fixed Windows/task.py | 2 +-
.../frontend/integration_test/tour_page_test.dart | 75 +-
learning/tour-of-beam/frontend/lib/main.dart | 1 +
.../frontend/lib/pages/tour/state.dart | 5 +
.../lib/pages/tour/widgets/playground.dart | 1 +
learning/tour-of-beam/frontend/pubspec.lock | 4 +-
.../learning-content/content-info.yaml | 4 +-
.../motivating-challenge-3/go-solution/main.go | 2 +-
.../module-info.yaml} | 13 +-
.../cross-language/multi-pipeline/description.md | 415 +
.../multi-pipeline/java-example/Task.java | 135 +
.../multi-pipeline/python-example/input.txt | 24 +
.../multi-pipeline/python-example/output.log | 21 +
.../multi-pipeline/python-example/task.py | 96 +
.../multi-pipeline/unit-info.yaml} | 15 +-
.../cross-language/sql-transform/description.md | 128 +
.../sql-transform/java-example/Task.java | 89 +
.../sql-transform/java-example/output.log | 17 +
.../sql-transform/python-example/output.log | 17 +
.../sql-transform/python-example}/task.py | 32 +-
.../sql-transform/unit-info.yaml} | 13 +-
.../from-memory/go-example/from_memory.go | 2 +-
.../reading-from-csv/go-example/csvExample.go | 2 +-
.../reading-from-text/go-example/textIo.go | 2 +-
.../creating-pipeline/go-example/main.go | 2 +-
.../runner-concepts/description.md | 75 +-
.../splittable-dofn/description.md | 129 +
.../splittable-dofn/go-example/main.go | 225 +
.../splittable-dofn/java-example/Task.java | 122 +
.../splittable-dofn/python-example/task.py | 74 +
.../unit-info.yaml} | 12 +-
playground/backend/containers/java/Dockerfile | 24 +
playground/backend/datasets/NYCTaxi1000Avro.avro | Bin 0 -> 76451 bytes
playground/backend/datasets/NYCTaxi1000Json.json | 18964 +++++++++++++++++++
.../backend/datasets/NYCTaxi1000_simpleAvro.avro | Bin 0 -> 2228 bytes
.../backend/datasets/NYCTaxi1000_simpleJson.json | 3994 ++++
playground/categories.yaml | 1 +
.../integration_test/initial_urls_test.dart | 1 -
.../miscellaneous_ui/output_placement_test.dart | 1 -
.../miscellaneous_ui/resize_output_test.dart | 1 -
.../miscellaneous_ui/shortcuts_modal_test.dart | 1 -
playground/frontend/lib/locator.dart | 1 -
.../modules/messages/parsers/messages_parser.dart | 3 +-
.../widgets/embedded_editor.dart | 1 +
.../widgets/editor_textarea_wrapper.dart | 1 +
playground/frontend/lib/playground_app.dart | 4 +-
playground/frontend/lib/router/page_factory.dart | 6 +-
.../lib/src/controllers/code_runner.dart | 29 +-
.../example_loaders/example_loader_factory.dart | 1 -
.../example_loaders/examples_loader.dart | 31 +-
.../example_loaders/standard_example_loader.dart | 31 +-
.../controllers/snippet_editing_controller.dart | 15 +
.../lib/src/exceptions/detailed_exception.dart} | 23 +-
.../lib/src/exceptions/multiple_exceptions.dart | 12 +-
.../lib/src/models/example.dart | 27 +
.../lib/src/services/toast_notifier.dart | 13 +
.../lib/src/widgets/output/result_tab_content.dart | 20 +
.../lib/src/widgets/snippet_editor.dart | 4 +
.../lib/src/widgets/snippet_file_editor.dart | 4 +-
.../lib/src/widgets/tabbed_snippet_editor.dart | 5 +-
.../frontend/playground_components/pubspec.yaml | 2 +-
.../example_loaders/examples_loader_test.dart | 10 +-
.../playground_components_dev/pubspec.yaml | 2 +-
playground/frontend/pubspec.lock | 12 +-
playground/frontend/pubspec.yaml | 4 +-
playground/terraform/infrastructure/setup/iam.tf | 2 +-
.../beam/runners/dataflow/DataflowRunner.java | 9 +-
.../dataflow/options/DataflowPipelineOptions.java | 7 -
.../beam/runners/dataflow/DataflowRunnerTest.java | 1 -
.../translation/ParDoBoundMultiTranslator.java | 9 +-
sdks/go.mod | 2 +-
sdks/go.sum | 4 +-
sdks/go/examples/contains/contains.go | 2 +-
.../debugging_wordcount/debugging_wordcount.go | 2 +-
sdks/go/examples/forest/forest.go | 2 +-
sdks/go/examples/grades/grades.go | 2 +-
.../minimal_wordcount/minimal_wordcount.go | 2 +-
sdks/go/examples/multiout/multiout.go | 2 +-
sdks/go/examples/stringsplit/stringsplit.go | 2 +-
.../windowed_wordcount/windowed_wordcount.go | 2 +-
sdks/go/examples/wordcount/wordcount.go | 2 +-
sdks/go/examples/yatzy/yatzy.go | 2 +-
sdks/go/pkg/beam/combine_test.go | 12 -
sdks/go/pkg/beam/core/timers/timers.go | 4 +-
sdks/go/pkg/beam/partition_test.go | 12 -
.../prism/internal/jobservices/management_test.go | 2 +-
.../go/pkg/beam/transforms/filter/distinct_test.go | 15 -
sdks/go/pkg/beam/transforms/filter/filter_test.go | 12 -
sdks/go/pkg/beam/transforms/periodic/periodic.go | 2 +-
.../pkg/beam/transforms/periodic/periodic_test.go | 4 +
.../container/license_scripts/dep_urls_java.yaml | 2 +-
.../apache/beam/sdk/testing/TestStreamTest.java | 12 -
.../apache/beam/sdk/transforms/CombineFnsTest.java | 13 -
.../org/apache/beam/sdk/transforms/FilterTest.java | 13 -
.../sdk/io/gcp/bigquery/BigQueryAvroUtils.java | 45 +-
.../sdk/io/gcp/bigquery/BigQueryAvroUtilsTest.java | 90 +
.../apache_beam/examples/avro_nyc_trips_it_test.py | 13 +-
.../examples/complete/game/user_score.py | 2 +-
.../examples/cookbook/combiners_test.py | 12 -
.../apache_beam/examples/cookbook/filters_test.py | 12 -
.../examples/cookbook/multiple_output_pardo.py | 2 +-
.../snippets_examples_wordcount_debugging.py | 14 +-
.../snippets_examples_wordcount_wordcount.py | 2 +-
.../transforms/aggregation/count_per_element.py | 4 +
.../snippets/transforms/aggregation/distinct.py | 4 +
.../aggregation/groupby_global_aggregate.py | 3 +-
.../snippets/transforms/elementwise/keys.py | 4 +
.../snippets/transforms/elementwise/kvswap.py | 4 +
.../transforms/elementwise/map_function.py | 4 +
.../snippets/transforms/elementwise/map_lambda.py | 4 +
.../elementwise/map_multiple_arguments.py | 4 +
.../transforms/elementwise/map_side_inputs_dict.py | 4 +
.../transforms/elementwise/map_side_inputs_iter.py | 4 +
.../elementwise/map_side_inputs_singleton.py | 4 +
.../snippets/transforms/elementwise/map_simple.py | 4 +
.../snippets/transforms/elementwise/map_tuple.py | 4 +
.../transforms/elementwise/tostring_iterables.py | 4 +
.../transforms/elementwise/tostring_kvs.py | 4 +
.../snippets/transforms/elementwise/values.py | 4 +
.../examples/streaming_wordcount_it_test.py | 14 -
sdks/python/apache_beam/examples/wordcount.py | 2 +-
.../apache_beam/examples/wordcount_debugging.py | 4 +-
.../apache_beam/examples/wordcount_minimal.py | 2 +-
.../apache_beam/examples/wordcount_minimal_test.py | 13 -
sdks/python/apache_beam/examples/wordcount_test.py | 13 -
.../io/azure/integration_test/Dockerfile | 2 +-
.../python/apache_beam/io/components}/__init__.py | 0
.../v1new => components}/adaptive_throttler.py | 2 +-
.../adaptive_throttler_test.py | 2 +-
sdks/python/apache_beam/io/components/util.py | 96 +
.../io/gcp/datastore/v1new/datastoreio.py | 2 +-
.../io/hdfs_integration_test/Dockerfile | 2 +-
sdks/python/apache_beam/metrics/metric_test.py | 12 -
sdks/python/apache_beam/runners/common.pxd | 2 +-
...low_exercise_streaming_metrics_pipeline_test.py | 13 -
.../runners/dataflow/dataflow_runner.py | 1 +
.../runners/dataflow/internal/apiclient.py | 4 +-
.../runners/dataflow/internal/apiclient_test.py | 59 +-
.../runners/direct/sdf_direct_runner.py | 4 +-
.../runners/portability/sdk_container_builder.py | 8 +-
sdks/python/apache_beam/transforms/util_test.py | 42 +-
sdks/python/apache_beam/utils/timestamp.py | 25 +-
sdks/python/apache_beam/utils/timestamp_test.py | 5 +
sdks/python/container/piputil.go | 10 +-
sdks/python/scripts/run_tox.sh | 6 +-
.../tensorrt_runinference/tensor_rt.dockerfile | 5 +-
sdks/python/tox.ini | 6 +-
website/www/site/assets/scss/_playground.sass | 1 +
website/www/site/content/en/blog/beam-2.48.0.md | 2 +
website/www/site/content/en/blog/beamquest.md | 9 +-
.../site/content/en/contribute/release-guide.md | 46 +-
.../java/aggregation/approximatequantiles.md | 5 +
.../transforms/java/aggregation/cogroupbykey.md | 9 +-
.../transforms/java/aggregation/combine.md | 9 +
.../transforms/java/aggregation/count.md | 13 +-
.../transforms/java/aggregation/distinct.md | 8 +-
.../transforms/java/aggregation/groupbykey.md | 6 +-
.../java/aggregation/groupintobatches.md | 5 +-
.../transforms/java/aggregation/latest.md | 10 +-
.../transforms/java/aggregation/max.md | 13 +
.../transforms/java/aggregation/mean.md | 15 +-
.../transforms/java/aggregation/min.md | 14 +-
.../transforms/java/aggregation/sample.md | 5 +-
.../transforms/java/aggregation/sum.md | 21 +-
.../transforms/java/aggregation/top.md | 5 +-
.../transforms/java/elementwise/filter.md | 7 +
.../transforms/java/elementwise/flatmapelements.md | 5 +-
.../transforms/java/elementwise/keys.md | 8 +-
.../transforms/java/elementwise/kvswap.md | 8 +-
.../transforms/java/elementwise/mapelements.md | 14 +-
.../transforms/java/elementwise/pardo.md | 6 +
.../transforms/java/elementwise/partition.md | 20 +-
.../transforms/java/elementwise/regex.md | 5 +-
.../transforms/java/elementwise/tostring.md | 5 +-
.../transforms/java/elementwise/values.md | 8 +-
.../transforms/java/elementwise/withkeys.md | 15 +-
.../transforms/java/elementwise/withtimestamps.md | 5 +-
.../documentation/transforms/java/other/create.md | 4 +-
.../documentation/transforms/java/other/flatten.md | 12 +-
.../en/documentation/transforms/java/other/view.md | 5 +-
.../documentation/transforms/java/other/window.md | 5 +-
.../python/aggregation/combineglobally.md | 56 +-
.../transforms/python/aggregation/combineperkey.md | 70 +-
.../transforms/python/aggregation/combinevalues.md | 70 +-
.../transforms/python/aggregation/count.md | 42 +-
.../transforms/python/aggregation/distinct.md | 14 +-
.../transforms/python/aggregation/groupby.md | 107 +-
.../transforms/python/aggregation/groupbykey.md | 8 +-
.../python/aggregation/groupintobatches.md | 14 +-
.../transforms/python/aggregation/latest.md | 28 +-
.../transforms/python/aggregation/max.md | 28 +-
.../transforms/python/aggregation/mean.md | 28 +-
.../transforms/python/aggregation/min.md | 28 +-
.../transforms/python/aggregation/sample.md | 28 +-
.../transforms/python/aggregation/sum.md | 28 +-
.../transforms/python/aggregation/top.md | 84 +-
.../transforms/python/elementwise/filter.md | 89 +-
.../transforms/python/elementwise/flatmap.md | 135 +-
.../transforms/python/elementwise/keys.md | 15 +-
.../transforms/python/elementwise/kvswap.md | 15 +-
.../transforms/python/elementwise/map.md | 120 +-
.../transforms/python/elementwise/pardo.md | 45 +-
.../transforms/python/elementwise/partition.md | 45 +-
.../transforms/python/elementwise/regex.md | 135 +-
.../transforms/python/elementwise/tostring.md | 45 +-
.../transforms/python/elementwise/values.md | 15 +-
.../python/elementwise/withtimestamps.md | 45 +-
.../transforms/python/other/create.md | 5 +-
.../transforms/python/other/flatten.md | 5 +-
.../transforms/python/other/windowinto.md | 5 +-
.../en/get-started/resources/learning-resources.md | 18 +
.../content/en/get-started/wordcount-example.md | 33 +
.../partials/section-menu/en/documentation.html | 6 +-
.../partials/section-menu/en/get-started.html | 3 +
.../static/images/blog/apch-beam-w_bdg_c_en.png | Bin 81879 -> 0 bytes
.../static/images/blog/beam-badge-image-scaled.png | Bin 0 -> 53129 bytes
298 files changed, 26522 insertions(+), 1830 deletions(-)
create mode 100644 examples/java/src/main/java/org/apache/beam/examples/KafkaPassengerCountJson.java
create mode 100644 examples/java/src/main/java/org/apache/beam/examples/KafkaStreaming.java
copy learning/tour-of-beam/learning-content/{content-info.yaml => cross-language/module-info.yaml} (86%)
create mode 100644 learning/tour-of-beam/learning-content/cross-language/multi-pipeline/description.md
create mode 100644 learning/tour-of-beam/learning-content/cross-language/multi-pipeline/java-example/Task.java
create mode 100644 learning/tour-of-beam/learning-content/cross-language/multi-pipeline/python-example/input.txt
create mode 100644 learning/tour-of-beam/learning-content/cross-language/multi-pipeline/python-example/output.log
create mode 100644 learning/tour-of-beam/learning-content/cross-language/multi-pipeline/python-example/task.py
copy learning/tour-of-beam/learning-content/{content-info.yaml => cross-language/multi-pipeline/unit-info.yaml} (85%)
create mode 100644 learning/tour-of-beam/learning-content/cross-language/sql-transform/description.md
create mode 100644 learning/tour-of-beam/learning-content/cross-language/sql-transform/java-example/Task.java
create mode 100644 learning/tour-of-beam/learning-content/cross-language/sql-transform/java-example/output.log
create mode 100644 learning/tour-of-beam/learning-content/cross-language/sql-transform/python-example/output.log
copy learning/{katas/python/Introduction/Hello Beam/Hello Beam => tour-of-beam/learning-content/cross-language/sql-transform/python-example}/task.py (52%)
copy learning/tour-of-beam/learning-content/{content-info.yaml => cross-language/sql-transform/unit-info.yaml} (85%)
create mode 100644 learning/tour-of-beam/learning-content/splittable-dofn/description.md
create mode 100644 learning/tour-of-beam/learning-content/splittable-dofn/go-example/main.go
create mode 100644 learning/tour-of-beam/learning-content/splittable-dofn/java-example/Task.java
create mode 100644 learning/tour-of-beam/learning-content/splittable-dofn/python-example/task.py
copy learning/tour-of-beam/learning-content/{content-info.yaml => splittable-dofn/unit-info.yaml} (86%)
create mode 100644 playground/backend/datasets/NYCTaxi1000Avro.avro
create mode 100644 playground/backend/datasets/NYCTaxi1000Json.json
create mode 100644 playground/backend/datasets/NYCTaxi1000_simpleAvro.avro
create mode 100644 playground/backend/datasets/NYCTaxi1000_simpleJson.json
copy playground/frontend/{lib/router/page_factory.dart => playground_components/lib/src/exceptions/detailed_exception.dart} (57%)
copy {examples/notebooks/notebook_test_scripts => sdks/python/apache_beam/io/components}/__init__.py (100%)
rename sdks/python/apache_beam/io/{gcp/datastore/v1new => components}/adaptive_throttler.py (98%)
rename sdks/python/apache_beam/io/{gcp/datastore/v1new => components}/adaptive_throttler_test.py (97%)
create mode 100644 sdks/python/apache_beam/io/components/util.py
delete mode 100644 website/www/site/static/images/blog/apch-beam-w_bdg_c_en.png
create mode 100644 website/www/site/static/images/blog/beam-badge-image-scaled.png