7cb69bdbed4d628718666c8bac694d4ce6968a3a - flink-statefun

commit	7cb69bdbed4d628718666c8bac694d4ce6968a3a	[log] [tgz]
author	Tzu-Li (Gordon) Tai <tzulitai@apache.org>	Thu Jan 21 15:23:26 2021 +0800
committer	Tzu-Li (Gordon) Tai <tzulitai@apache.org>	Fri Jan 22 00:01:15 2021 +0800
tree	ce25eca8d161519472b3c0c79c751057da21f675
parent	d3112ed68607f082b8036420e7b470de6470b479 [diff]

[FLINK-21061] [core] Support state types for remote function states

This closes #193.

statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/reqreply/PersistedRemoteFunctionValues.java[diff]
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/state/FlinkState.java[diff]
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/state/FlinkStateBinder.java[diff]
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/state/PersistedStates.java[diff]
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/state/State.java[diff]
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/types/remote/RemoteValueSerializer.java[Added - diff]
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/types/remote/RemoteValueSerializerSnapshot.java[Added - diff]
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/types/remote/RemoteValueTypeInfo.java[Added - diff]
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/types/remote/RemoteValueTypeMismatchException.java[Added - diff]
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/sdk/state/ApiExtension.java[diff]
statefun-flink/statefun-flink-core/src/main/protobuf/request-reply.proto[diff]
statefun-flink/statefun-flink-core/src/test/java/org/apache/flink/statefun/flink/core/reqreply/PersistedRemoteFunctionValuesTest.java[diff]
statefun-flink/statefun-flink-core/src/test/java/org/apache/flink/statefun/flink/core/state/PersistedStatesTest.java[diff]
statefun-flink/statefun-flink-state-processor/src/test/java/org/apache/flink/statefun/flink/state/processor/operator/StateBootstrapperTest.java[diff]
statefun-sdk/src/main/java/org/apache/flink/statefun/sdk/TypeName.java[Added - diff]
statefun-sdk/src/main/java/org/apache/flink/statefun/sdk/state/PersistedStateRegistry.java[diff]
statefun-sdk/src/main/java/org/apache/flink/statefun/sdk/state/RemotePersistedValue.java[Added - diff]
statefun-sdk/src/test/java/org/apache/flink/statefun/sdk/state/PersistedStateRegistryTest.java[diff]

18 files changed

tree: ce25eca8d161519472b3c0c79c751057da21f675