This is an automated email from the ASF dual-hosted git repository.
tzulitai pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink-statefun.git.
from ec69df6 [hotfix] Temporary disable E2E tests in CI
add 96cd004 [FLINK-21457] Add support to differentiate a zero length
value bytes and non existing value
new 20b521e [FLINK-21459] Implement remote Java SDK for Stateful Functions
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../flink/common/types/TypedValueUtil.java | 1 +
.../protorouter/AutoRoutableProtobufRouter.java | 6 +-
.../reqreply/PersistedRemoteFunctionValues.java | 3 +-
.../PersistedRemoteFunctionValuesTest.java | 6 +-
.../core/reqreply/RequestReplyFunctionTest.java | 2 +
statefun-sdk-java/pom.xml | 19 +-
.../java/com/google/protobuf/MoreByteStrings.java | 23 +-
.../apache/flink/statefun/sdk/java}/Address.java | 16 +-
.../statefun/sdk/java/AddressScopedStorage.java | 16 +-
.../flink/statefun/sdk/java/ApiExtension.java | 20 +-
.../apache/flink/statefun/sdk/java/Context.java | 31 +-
.../flink/statefun/sdk/java}/Expiration.java | 8 +-
.../flink/statefun/sdk/java/StatefulFunction.java | 26 +-
.../statefun/sdk/java/StatefulFunctionSpec.java | 78 ++++
.../flink/statefun/sdk/java/StatefulFunctions.java | 36 +-
.../apache/flink/statefun/sdk/java/TypeName.java | 59 ++-
.../apache/flink/statefun/sdk/java/ValueSpec.java | 115 ++++++
.../statefun/sdk/java/annotations/Internal.java | 8 +-
.../sdk/java/handler/ConcurrentContext.java | 147 +++++++
.../handler/ConcurrentRequestReplyHandler.java | 150 +++++++
.../statefun/sdk/java/handler/MoreFutures.java | 66 +++
.../statefun/sdk/java/handler/ProtoUtils.java | 97 +++++
.../sdk/java/handler/RequestReplyHandler.java | 16 +-
.../statefun/sdk/java/io/KafkaEgressMessage.java | 127 ++++++
.../statefun/sdk/java/io/KinesisEgressMessage.java | 146 +++++++
.../statefun/sdk/java/message/EgressMessage.java | 26 +-
.../sdk/java/message/EgressMessageWrapper.java | 55 +++
.../flink/statefun/sdk/java/message/Message.java | 43 +-
.../statefun/sdk/java/message/MessageBuilder.java | 113 +++++
.../statefun/sdk/java/message/MessageWrapper.java | 133 ++++++
.../statefun/sdk/java/slice/ByteStringSlice.java | 80 ++++
.../flink/statefun/sdk/java/slice/Slice.java | 25 +-
.../flink/statefun/sdk/java/slice/SliceOutput.java | 108 +++++
.../statefun/sdk/java/slice/SliceProtobufUtil.java | 55 +++
.../flink/statefun/sdk/java/slice/Slices.java | 61 +++
.../storage/ConcurrentAddressScopedStorage.java | 347 ++++++++++++++++
.../storage/IllegalStorageAccessException.java | 10 +-
.../sdk/java/storage/StateValueContexts.java | 131 ++++++
.../flink/statefun/sdk/java/types/SimpleType.java | 104 +++++
.../apache/flink/statefun/sdk/java/types/Type.java | 17 +-
.../sdk/java/types/TypeCharacteristics.java | 6 +-
.../statefun/sdk/java/types/TypeSerializer.java | 9 +-
.../flink/statefun/sdk/java/types/Types.java | 456 +++++++++++++++++++++
.../handler/ConcurrentRequestReplyHandlerTest.java | 116 ++++++
.../statefun/sdk/java/handler/MoreFuturesTest.java | 93 +++++
.../flink/statefun/sdk/java/handler/TestUtils.java | 96 +++++
.../statefun/sdk/java/slice/SliceOutputTest.java | 144 +++++++
.../sdk/java/slice/SliceProtobufUtilTest.java | 20 +-
.../ConcurrentAddressScopedStorageTest.java | 206 ++++++++++
.../sdk/java/storage/StateValueContextsTest.java | 150 +++++++
.../statefun/sdk/java/storage/TestMutableType.java | 77 ++++
.../sdk/java/types/SanityPrimitiveTypeTest.java | 194 +++++++++
.../src/main/protobuf/sdk/request-reply.proto | 5 +-
53 files changed, 3919 insertions(+), 183 deletions(-)
copy
statefun-examples/statefun-ridesharing-example/statefun-ridesharing-example-simulator/src/main/java/org/apache/flink/statefun/examples/ridesharing/simulator/simulation/engine/LifecycleMessages.java
=> statefun-sdk-java/src/main/java/com/google/protobuf/MoreByteStrings.java
(63%)
copy {statefun-sdk/src/main/java/org/apache/flink/statefun/sdk =>
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java}/Address.java
(81%)
copy
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/jsonmodule/FunctionSpec.java
=>
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/AddressScopedStorage.java
(77%)
copy
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/common/ManagingResources.java
=>
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/ApiExtension.java
(67%)
copy
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/reqreply/RequestReplyClient.java
=>
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/Context.java
(60%)
copy {statefun-sdk/src/main/java/org/apache/flink/statefun/sdk/state =>
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java}/Expiration.java
(91%)
copy statefun-examples/statefun-python-walkthrough-example/walkthrough.proto
=>
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/StatefulFunction.java
(74%)
create mode 100644
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/StatefulFunctionSpec.java
copy
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/grpcfn/GrpcFunctionProvider.java
=>
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/StatefulFunctions.java
(50%)
copy
statefun-sdk/src/main/java/org/apache/flink/statefun/sdk/FunctionType.java =>
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/TypeName.java
(53%)
create mode 100644
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/ValueSpec.java
copy
statefun-sdk/src/main/java/org/apache/flink/statefun/sdk/annotations/ForRuntime.java
=>
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/annotations/Internal.java
(82%)
create mode 100644
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/handler/ConcurrentContext.java
create mode 100644
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/handler/ConcurrentRequestReplyHandler.java
create mode 100644
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/handler/MoreFutures.java
create mode 100644
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/handler/ProtoUtils.java
copy
statefun-examples/statefun-async-example/src/main/java/org/apache/flink/statefun/examples/async/service/TaskQueryService.java
=>
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/handler/RequestReplyHandler.java
(64%)
create mode 100644
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/io/KafkaEgressMessage.java
create mode 100644
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/io/KinesisEgressMessage.java
copy statefun-examples/statefun-python-walkthrough-example/walkthrough.proto
=>
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/message/EgressMessage.java
(73%)
create mode 100644
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/message/EgressMessageWrapper.java
copy
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/metrics/FunctionTypeMetrics.java
=>
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/message/Message.java
(54%)
create mode 100644
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/message/MessageBuilder.java
create mode 100644
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/message/MessageWrapper.java
create mode 100644
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/slice/ByteStringSlice.java
copy
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/logger/FeedbackLogger.java
=>
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/slice/Slice.java
(68%)
create mode 100644
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/slice/SliceOutput.java
create mode 100644
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/slice/SliceProtobufUtil.java
create mode 100644
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/slice/Slices.java
create mode 100644
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/storage/ConcurrentAddressScopedStorage.java
copy
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/jsonmodule/ModuleConfigurationException.java
=>
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/storage/IllegalStorageAccessException.java
(75%)
create mode 100644
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/storage/StateValueContexts.java
create mode 100644
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/types/SimpleType.java
copy
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/jsonmodule/FunctionSpec.java
=>
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/types/Type.java
(70%)
copy
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/jsonmodule/ModuleType.java
=>
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/types/TypeCharacteristics.java
(88%)
copy
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/metrics/FunctionDispatcherMetrics.java
=>
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/types/TypeSerializer.java
(80%)
create mode 100644
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/types/Types.java
create mode 100644
statefun-sdk-java/src/test/java/org/apache/flink/statefun/sdk/java/handler/ConcurrentRequestReplyHandlerTest.java
create mode 100644
statefun-sdk-java/src/test/java/org/apache/flink/statefun/sdk/java/handler/MoreFuturesTest.java
create mode 100644
statefun-sdk-java/src/test/java/org/apache/flink/statefun/sdk/java/handler/TestUtils.java
create mode 100644
statefun-sdk-java/src/test/java/org/apache/flink/statefun/sdk/java/slice/SliceOutputTest.java
copy
statefun-e2e-tests/statefun-smoke-e2e/src/test/java/org/apache/flink/statefun/e2e/smoke/SmokeVerificationE2E.java
=>
statefun-sdk-java/src/test/java/org/apache/flink/statefun/sdk/java/slice/SliceProtobufUtilTest.java
(64%)
create mode 100644
statefun-sdk-java/src/test/java/org/apache/flink/statefun/sdk/java/storage/ConcurrentAddressScopedStorageTest.java
create mode 100644
statefun-sdk-java/src/test/java/org/apache/flink/statefun/sdk/java/storage/StateValueContextsTest.java
create mode 100644
statefun-sdk-java/src/test/java/org/apache/flink/statefun/sdk/java/storage/TestMutableType.java
create mode 100644
statefun-sdk-java/src/test/java/org/apache/flink/statefun/sdk/java/types/SanityPrimitiveTypeTest.java
