This is an automated email from the ASF dual-hosted git repository.
aglinxinyuan pushed a change to branch xinyuan-state-materialization
in repository https://gitbox.apache.org/repos/asf/texera.git
from 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
No new revisions were added by this update.
Summary of changes:
.../core/architecture/packaging/output_manager.py | 13 ++----
amber/src/main/python/core/models/payload.py | 4 --
amber/src/main/python/core/models/state.py | 34 +++++++-------
.../main/python/core/runnables/network_receiver.py | 15 ++----
.../main/python/core/runnables/network_sender.py | 14 ++----
.../python/core/runnables/test_network_receiver.py | 5 +-
.../core/storage/iceberg/test_iceberg_document.py | 53 +++++++++++-----------
.../input_port_materialization_reader_runnable.py | 5 +-
.../messaginglayer/OutputManager.scala | 4 +-
.../pythonworker/PythonProxyClient.scala | 2 +-
.../pythonworker/PythonProxyServer.scala | 2 +-
.../scheduling/RegionExecutionCoordinator.scala | 2 +-
.../InputPortMaterializationReaderThread.scala | 4 +-
.../org/apache/texera/amber/core/state/State.scala | 34 ++++++++------
.../result/iceberg/IcebergDocumentSpec.scala | 38 +++++++++-------
15 files changed, 107 insertions(+), 122 deletions(-)
