You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by ig...@apache.org on 2022/02/10 13:59:05 UTC

[flink-statefun] branch master updated (1054c17 -> 7ec6664)

This is an automated email from the ASF dual-hosted git repository.

igal pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink-statefun.git.


    from 1054c17  [hotfix][doc] Typo in link.
     add 7ec6664  [FLINK-25933][statefun] Add support for the async HTTP transport in request-reply function builder

No new revisions were added by this update.

Summary of changes:
 docs/content/docs/sdk/flink-datastream.md          |  11 +-
 .../httpfn/DefaultHttpRequestReplyClientSpec.java  |  17 ++-
 .../NettyRequestReplyClientFactory.java            |   3 +
 .../core/nettyclient/NettyRequestReplySpec.java    |  51 +++++---
 .../core/nettyclient/NettyTransportModule.java     |   3 +-
 .../AsyncRequestReplyFunctionBuilder.java          | 132 +++++++++++++++++++++
 .../datastream/RequestReplyFunctionBuilder.java    |  32 +++--
 .../SerializableHttpFunctionProvider.java          |  22 +++-
 .../flink/datastream/StatefulFunctionBuilder.java  |  63 ++++++++++
 .../StatefulFunctionDataStreamBuilder.java         |  13 +-
 .../AsyncRequestReplyFunctionBuilderTest.java      | 125 +++++++++++++++++++
 .../RequestReplyFunctionBuilderTest.java           |  95 ++++++++++++++-
 ...a => SerializableHttpFunctionProviderTest.java} |  27 +++--
 13 files changed, 531 insertions(+), 63 deletions(-)
 create mode 100644 statefun-flink/statefun-flink-datastream/src/main/java/org/apache/flink/statefun/flink/datastream/AsyncRequestReplyFunctionBuilder.java
 create mode 100644 statefun-flink/statefun-flink-datastream/src/main/java/org/apache/flink/statefun/flink/datastream/StatefulFunctionBuilder.java
 create mode 100644 statefun-flink/statefun-flink-datastream/src/test/java/org/apache/flink/statefun/flink/datastream/AsyncRequestReplyFunctionBuilderTest.java
 copy statefun-flink/statefun-flink-datastream/src/test/java/org/apache/flink/statefun/flink/datastream/{RequestReplyFunctionBuilderTest.java => SerializableHttpFunctionProviderTest.java} (50%)