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 007a264b59 refactor(amber): carry loop_counter off State on the
StateFrame envelope
add 63d243353a refactor(amber): fold the loop_counter column onto State,
drop StateStorage
No new revisions were added by this update.
Summary of changes:
.../core/architecture/packaging/output_manager.py | 8 ++--
amber/src/main/python/core/models/__init__.py | 2 -
amber/src/main/python/core/models/state.py | 15 ++++--
amber/src/main/python/core/models/state_storage.py | 56 ----------------------
amber/src/main/python/core/runnables/main_loop.py | 5 +-
.../main/python/core/runnables/network_receiver.py | 5 +-
.../main/python/core/runnables/network_sender.py | 8 ++--
.../input_port_materialization_reader_runnable.py | 10 ++--
.../messaginglayer/OutputManager.scala | 4 +-
.../pythonworker/PythonProxyClient.scala | 3 +-
.../scheduling/RegionExecutionCoordinator.scala | 4 +-
.../packaging/test_state_materialization_e2e.py | 13 ++---
amber/src/test/python/core/models/test_state.py | 19 ++++++--
...t_input_port_materialization_reader_runnable.py | 18 +++----
.../org/apache/texera/amber/core/state/State.scala | 12 +++--
.../texera/amber/core/state/StateStorage.scala | 56 ----------------------
.../apache/texera/amber/core/state/StateSpec.scala | 8 ++--
.../texera/amber/core/state/StateStorageSpec.scala | 51 --------------------
.../result/iceberg/IcebergDocumentSpec.scala | 4 +-
19 files changed, 79 insertions(+), 222 deletions(-)
delete mode 100644 amber/src/main/python/core/models/state_storage.py
delete mode 100644
common/workflow-core/src/main/scala/org/apache/texera/amber/core/state/StateStorage.scala
delete mode 100644
common/workflow-core/src/test/scala/org/apache/texera/amber/core/state/StateStorageSpec.scala
