galenwarren opened a new pull request #300: URL: https://github.com/apache/flink-statefun/pull/300
The objective here is to allow users who build Statefun jobs in code -- using RequestReplyFunctionBuilder and related classes -- to choose the newer, async HTTP transport for remote function class. Previously, only the sync HTTP transport was supported. The synchronous and asynchronous transports have different sets of configurable properties -- neither of which is a subset of the other -- so the existing `RequestReplyFunctionBuilder` continues to be used to build sync functions, and the new `AsyncRequestReplyFunctionBuilder` is used to build async functions. Each of these derive from a new common base class, `StatefulFunctionBuilder`. `StatefulFunctionBuilder` has factory methods `requestReplyFunctionBuilder` and `asyncRequestReplyFunctionBuilder` to create sync and async builders, and the factory method `requestReplyFunctionBuilder` on `RequestReplyFunctionBuilder` is deprecated. The `SerializableHttpFunctionProvider` class is updated to properly choose the transport client based on the spec; previously, it always chose the sync client. Added unit tests and updated docs. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
