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 8e8f650 [Docs] Draft the barebones of project docs (#191)
add 23bce98 [Feature] Implemenet Kafka-based state store (#181)
No new revisions were added by this update.
Summary of changes:
.../api/configuration/AgentConfigOptions.java | 16 +
.../flink/agents/api/context/MemoryUpdate.java | 10 +-
pom.xml | 1 +
runtime/pom.xml | 7 +-
.../agents/runtime/actionstate/ActionState.java | 33 ++-
.../actionstate/ActionStateKafkaDeserializer.java | 110 +++++++
.../runtime/actionstate/ActionStateKafkaSeder.java | 123 ++++++++
.../actionstate/ActionStateKafkaSerializer.java | 108 +++++++
.../actionstate/ActionStateKeyPartitioner.java | 60 ++++
.../runtime/actionstate/ActionStateStore.java | 8 +-
.../runtime/actionstate/KafkaActionStateStore.java | 323 ++++++++++++++++++++-
.../runtime/operator/ActionExecutionOperator.java | 42 ++-
.../actionstate/ActionStateKeyPartitionerTest.java | 245 ++++++++++++++++
.../runtime/actionstate/ActionStateSerdeTest.java | 131 +++++++++
.../actionstate/InMemoryActionStateStore.java | 5 +
.../actionstate/KafkaActionStateStoreTest.java | 271 +++++++++++++++++
.../operator/ActionExecutionOperatorTest.java | 3 -
17 files changed, 1439 insertions(+), 57 deletions(-)
create mode 100644
runtime/src/main/java/org/apache/flink/agents/runtime/actionstate/ActionStateKafkaDeserializer.java
create mode 100644
runtime/src/main/java/org/apache/flink/agents/runtime/actionstate/ActionStateKafkaSeder.java
create mode 100644
runtime/src/main/java/org/apache/flink/agents/runtime/actionstate/ActionStateKafkaSerializer.java
create mode 100644
runtime/src/main/java/org/apache/flink/agents/runtime/actionstate/ActionStateKeyPartitioner.java
create mode 100644
runtime/src/test/java/org/apache/flink/agents/runtime/actionstate/ActionStateKeyPartitionerTest.java
create mode 100644
runtime/src/test/java/org/apache/flink/agents/runtime/actionstate/ActionStateSerdeTest.java
create mode 100644
runtime/src/test/java/org/apache/flink/agents/runtime/actionstate/KafkaActionStateStoreTest.java
