This is an automated email from the ASF dual-hosted git repository.
ningk pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from ab67f1e Minor: Restore "Bugfix" section in CHANGES.md (#15516)
new af69e6df [BEAM-10708] Introspect beam_sql output
new 1723745 Merge pull request #15490 from KevinGG/beam_sql_out_cache
The 32964 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
sdks/python/apache_beam/pipeline.py | 5 +-
.../runners/interactive/augmented_pipeline.py | 2 -
.../runners/interactive/background_caching_job.py | 7 +-
.../runners/interactive/caching/cacheable.py | 48 +++-
.../runners/interactive/caching/read_cache.py | 22 +-
.../runners/interactive/caching/read_cache_test.py | 5 +-
.../runners/interactive/caching/reify.py | 117 +++++++++
.../runners/interactive/caching/write_cache.py | 34 +--
.../interactive/caching/write_cache_test.py | 6 +-
.../interactive/display/pcoll_visualization.py | 17 ++
.../runners/interactive/display/pipeline_graph.py | 4 +-
.../runners/interactive/interactive_environment.py | 15 +-
.../runners/interactive/interactive_runner.py | 3 +-
.../messaging/interactive_environment_inspector.py | 9 +-
.../runners/interactive/pipeline_fragment.py | 2 +-
.../runners/interactive/pipeline_instrument.py | 281 ++++++---------------
.../interactive/pipeline_instrument_test.py | 178 ++++++-------
.../runners/interactive/recording_manager.py | 54 ++--
.../runners/interactive/recording_manager_test.py | 31 +--
.../runners/interactive/sql/beam_sql_magics.py | 130 +++++-----
.../interactive/sql/beam_sql_magics_test.py | 43 +++-
.../apache_beam/runners/interactive/sql/utils.py | 22 +-
.../runners/interactive/sql/utils_test.py | 15 +-
.../Darwin/29c9237ddf4f3d5988a503069b4d3c47.png | Bin 67298 -> 67304 bytes
.../Darwin/7a35f487b2a5f3a9b9852a8659eeb4bd.png | Bin 760584 -> 750380 bytes
.../runners/interactive/user_pipeline_tracker.py | 5 +
.../apache_beam/runners/interactive/utils.py | 97 +++++++
.../apache_beam/runners/interactive/utils_test.py | 38 +++
sdks/python/setup.py | 2 +-
29 files changed, 677 insertions(+), 515 deletions(-)
create mode 100644 sdks/python/apache_beam/runners/interactive/caching/reify.py
