Sign in
◑
Theme
apache
/
flink-statefun
/
e1b0c2918939879112a297612fc429ad05bbe4a6
commit
e1b0c2918939879112a297612fc429ad05bbe4a6
[
log
]
author
Igal Shilman <igalshilman@gmail.com>
Mon Jun 14 12:45:10 2021 +0200
committer
Tzu-Li (Gordon) Tai <tzulitai@apache.org>
Thu Jul 08 14:08:28 2021 +0800
tree
826d83a75047bc130e2b1c5df4eb56f1da37000a
parent
dbf62f7e36021897e8010e66a66fdb9e96ce4e3c
[
diff
]
[FLINK-21308][core] Support delayed message cancellation This closes #241.
statefun-e2e-tests/statefun-smoke-e2e/src/test/java/org/apache/flink/statefun/e2e/smoke/CommandInterpreterTest.java
[
diff
]
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions/AsyncMessageDecorator.java
[
diff
]
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions/DelayMessageHandler.java
[Added -
diff
]
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions/DelaySink.java
[
diff
]
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions/DelayedMessagesBuffer.java
[
diff
]
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions/FlinkStateDelayedMessagesBuffer.java
[
diff
]
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions/FunctionGroupOperator.java
[
diff
]
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions/Reductions.java
[
diff
]
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions/ReusableContext.java
[
diff
]
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/message/Message.java
[
diff
]
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/message/MessageFactory.java
[
diff
]
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/message/ProtobufMessage.java
[
diff
]
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/message/SdkMessage.java
[
diff
]
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/reqreply/RequestReplyFunction.java
[
diff
]
statefun-flink/statefun-flink-core/src/main/protobuf/stateful-functions.proto
[
diff
]
statefun-flink/statefun-flink-core/src/test/java/org/apache/flink/statefun/flink/core/functions/LocalStatefulFunctionGroupTest.java
[
diff
]
statefun-flink/statefun-flink-core/src/test/java/org/apache/flink/statefun/flink/core/functions/ReductionsTest.java
[
diff
]
statefun-flink/statefun-flink-core/src/test/java/org/apache/flink/statefun/flink/core/reqreply/RequestReplyFunctionTest.java
[
diff
]
statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/Context.java
[
diff
]
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/Context.java
[
diff
]
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/handler/ConcurrentContext.java
[
diff
]
statefun-sdk-protos/src/main/protobuf/sdk/request-reply.proto
[
diff
]
statefun-sdk-python/statefun/context.py
[
diff
]
statefun-sdk-python/statefun/request_reply_v3.py
[
diff
]
statefun-sdk-python/tests/request_reply_test.py
[
diff
]
statefun-testutil/src/main/java/org/apache/flink/statefun/testutils/function/TestContext.java
[
diff
]
26 files changed
tree: 826d83a75047bc130e2b1c5df4eb56f1da37000a
.github/
docs/
licenses/
statefun-e2e-tests/
statefun-flink/
statefun-kafka-io/
statefun-kinesis-io/
statefun-sdk-embedded/
statefun-sdk-java/
statefun-sdk-protos/
statefun-sdk-python/
statefun-shaded/
statefun-testutil/
tools/
.asf.yaml
.gitignore
.gitmodules
CODE_OF_CONDUCT.md
LICENSE
NOTICE
pom.xml
README.md
README.zh.md