This is an automated email from the ASF dual-hosted git repository.
linxinyuan pushed a change to branch xinyuan-loop-feb
in repository https://gitbox.apache.org/repos/asf/texera.git
from 754d4d19be Merge branch 'xiaozhen-sync-region-kill' into
xinyuan-loop-feb
add a35df2f85e update
No new revisions were added by this update.
Summary of changes:
.../core/architecture/packaging/input_manager.py | 6 +-
.../core/architecture/packaging/output_manager.py | 22 ++-
amber/src/main/python/core/runnables/main_loop.py | 18 +--
.../input_port_materialization_reader_runnable.py | 12 +-
.../python/core/storage/state_materialization.py | 100 +++++++++++++
.../messaginglayer/OutputManager.scala | 8 +-
.../scheduling/RegionExecutionCoordinator.scala | 6 +
.../InputPortMaterializationReaderThread.scala | 11 +-
.../amber/core/state/StateMaterialization.scala | 160 +++++++++++++++++++++
.../texera/amber/operator/loop/LoopEndOpDesc.scala | 8 +-
10 files changed, 318 insertions(+), 33 deletions(-)
create mode 100644 amber/src/main/python/core/storage/state_materialization.py
create mode 100644
common/workflow-core/src/main/scala/org/apache/texera/amber/core/state/StateMaterialization.scala
