This is an automated email from the ASF dual-hosted git repository.
xtsong pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/flink-agents.git
from 393b9ec [infra] Run e2e tests in ci.
add db94eff [api][runtime][java] Introduce sensory memory in java.
add 680bba9 [api][runtime][python] Introduce sensory memory in python.
No new revisions were added by this update.
Summary of changes:
.../flink/agents/api/context/MemoryObject.java | 4 +
.../apache/flink/agents/api/context/MemoryRef.java | 16 +++-
.../flink/agents/api/context/RunnerContext.java | 11 +++
.../agents/integration/test/MemoryObjectAgent.java | 91 ++++++++++++++++------
python/flink_agents/api/memory_object.py | 6 ++
python/flink_agents/api/memory_reference.py | 17 +++-
python/flink_agents/api/runner_context.py | 15 ++++
python/flink_agents/runtime/flink_memory_object.py | 14 ++--
.../flink_agents/runtime/flink_runner_context.py | 20 ++++-
python/flink_agents/runtime/local_memory_object.py | 12 +--
python/flink_agents/runtime/local_runner.py | 31 +++++++-
.../runtime/tests/test_local_memory_object.py | 3 +-
.../runtime/tests/test_memory_reference.py | 9 ++-
.../agents/runtime/actionstate/ActionState.java | 53 +++++++++----
.../agents/runtime/context/RunnerContextImpl.java | 48 +++++++++---
.../agents/runtime/memory/CachedMemoryStore.java | 5 ++
.../agents/runtime/memory/MemoryObjectImpl.java | 15 ++--
.../flink/agents/runtime/memory/MemoryStore.java | 3 +
.../runtime/operator/ActionExecutionOperator.java | 31 +++++++-
.../python/context/PythonRunnerContextImpl.java | 10 ++-
.../runtime/actionstate/ActionStateSerdeTest.java | 26 +++++--
.../agents/runtime/memory/MemoryObjectTest.java | 5 +-
.../flink/agents/runtime/memory/MemoryRefTest.java | 19 +++--
.../operator/ActionExecutionOperatorTest.java | 7 +-
24 files changed, 369 insertions(+), 102 deletions(-)
