This is an automated email from the ASF dual-hosted git repository.
aglinxinyuan pushed a change to branch xinyuan-loop-feb
in repository https://gitbox.apache.org/repos/asf/texera.git
from a4827cdcb7 Merge branch 'main' into xinyuan-loop-feb
add 84bd376983 refactor: keep only state changes on top of main
add b570aaef73 refactor: keep state changes without materialization
add 3c0c8164e7 feat: add state materialization support
add bd1bc287ff fix: keep only materialization change in region coordinator
add 272caff584 chore: drop local AGENTS file from branch
add e7a0f15f3d test: cover state materialization round trip
add 3c4dbb8ff8 test: cover multiple state rows in materialization
add 193e7d36b0 Merge branch 'main' into xinyuan-state-materialization
add cb1d9e13b1 fix fmt
add 3df8fef073 Merge branch 'main' into xinyuan-state-only
add fc8cdf83b0 init
add 5c1d3696b8 update
add 8d3a45c56a Merge branch 'main' into xinyuan-remove-passToAllDownstream
add c4a5f6cc43 Merge branch 'main' into xinyuan-remove-passToAllDownstream
add a0e4e21fb5 Merge branch 'main' into xinyuan-remove-passToAllDownstream
add 92000949bd Merge branch 'main' into xinyuan-remove-passToAllDownstream
add f4b40a5ae8 Merge branch 'xinyuan-remove-passToAllDownstream' into
xinyuan-state-only
add 09537cb0be Merge branch 'xinyuan-state-only' into
xinyuan-state-materialization
add 2484147fbc Merge branch 'main' into xinyuan-state-only
add 24ac4ed943 Merge branch 'main' into xinyuan-state-only
add cd6809db8d Merge branch 'xinyuan-state-only' into
xinyuan-state-materialization
add 8a72f8dcff Merge branch 'main' into xinyuan-state-only
add 60db011cc0 fix: address state review comments
add 74e2b1da7f update
add 2fe32703c5 update
add 87330ecc2a update
add d545e7dab0 Merge branch 'main' into xinyuan-state-only
add 2716fc5e0a Merge branch 'main' into xinyuan-state-only
add 28a412bd92 Merge branch 'main' into xinyuan-state-only
add 3b8ec8e324 fix: make python State runtime type
add 15a1bc8862 Merge branch 'main' into xinyuan-state-only
add 70d4a9a0e8 Merge branch 'xinyuan-state-only' into
xinyuan-state-materialization
add 075697202a refactor: drop StateFrame.__post_init__ auto-coerce
add d92ed51b1c fix fmt
add 2a8966e936 refactor(scala): move State serializers into the State class
add 9be8139ca5 Merge xinyuan-state-only + adapt callers to in-class State
API
add 89e2276425 Merge xinyuan-state-materialization into xinyuan-loop-feb
add fbd2a4dff7 Merge branch 'xinyuan-loop-feb' of github.com:apache/texera
into xinyuan-loop-feb
No new revisions were added by this update.
Summary of changes:
.../core/architecture/packaging/output_manager.py | 15 ++--
amber/src/main/python/core/models/state.py | 40 +++++------
.../main/python/core/runnables/data_processor.py | 2 +
amber/src/main/python/core/runnables/main_loop.py | 13 ++--
.../main/python/core/runnables/network_receiver.py | 23 +++---
.../main/python/core/runnables/network_sender.py | 16 +----
.../main/python/core/runnables/test_main_loop.py | 55 +++++---------
.../python/core/runnables/test_network_receiver.py | 39 +++++++++-
.../core/storage/iceberg/test_iceberg_document.py | 83 ++++++++++++++++++++++
.../input_port_materialization_reader_runnable.py | 5 +-
.../messaginglayer/OutputManager.scala | 4 +-
.../pythonworker/PythonProxyServer.scala | 2 +-
.../scheduling/RegionExecutionCoordinator.scala | 3 +-
.../InputPortMaterializationReaderThread.scala | 4 +-
.../org/apache/texera/amber/core/state/State.scala | 41 +++++++----
.../apache/texera/amber/core/state/package.scala | 24 -------
.../result/iceberg/IcebergDocumentSpec.scala | 70 ++++++++++++++++++
17 files changed, 287 insertions(+), 152 deletions(-)
delete mode 100644
common/workflow-core/src/main/scala/org/apache/texera/amber/core/state/package.scala
