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 367f7bef39 Merge branch 'xiaozhen-sync-region-kill' into
xinyuan-loop-feb
add db819e2d67 fix fmt
No new revisions were added by this update.
Summary of changes:
.../core/architecture/packaging/output_manager.py | 3 +-
amber/src/main/python/core/models/operator.py | 13 +--
amber/src/main/python/core/models/state.py | 80 +--------------
.../main/python/core/runnables/data_processor.py | 2 +-
amber/src/main/python/core/runnables/main_loop.py | 18 ++--
.../main/python/core/runnables/network_receiver.py | 15 ++-
.../main/python/core/runnables/network_sender.py | 23 +++--
...materialization.py => loop_state_json_serde.py} | 39 +-------
.../input_port_materialization_reader_runnable.py | 2 +-
.../python/core/storage/state_materialization.py | 57 ++---------
.../pythonworker/PythonProxyClient.scala | 7 +-
.../pythonworker/PythonProxyServer.scala | 7 +-
.../amber/core/executor/OperatorExecutor.scala | 8 +-
.../amber/core/state/LoopStateJsonSerde.scala | 90 +++++++++++++++++
.../org/apache/texera/amber/core/state/State.scala | 58 -----------
.../amber/core/state/StateMaterialization.scala | 107 ++-------------------
.../apache/texera/amber/core/state/package.scala} | 6 +-
.../amber/operator/ifStatement/IfOpExec.scala | 2 +-
.../texera/amber/operator/loop/LoopEndOpDesc.scala | 9 +-
19 files changed, 180 insertions(+), 366 deletions(-)
copy amber/src/main/python/core/storage/{state_materialization.py =>
loop_state_json_serde.py} (64%)
create mode 100644
common/workflow-core/src/main/scala/org/apache/texera/amber/core/state/LoopStateJsonSerde.scala
delete mode 100644
common/workflow-core/src/main/scala/org/apache/texera/amber/core/state/State.scala
copy
common/{workflow-operator/src/main/scala/org/apache/texera/amber/operator/sort/SortPreference.java
=>
workflow-core/src/main/scala/org/apache/texera/amber/core/state/package.scala}
(89%)
