Zakelly commented on code in PR #24657:
URL: https://github.com/apache/flink/pull/24657#discussion_r1568151628
##########
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/asyncprocessing/AsyncStateProcessing.java:
##########
@@ -34,19 +34,6 @@ public interface AsyncStateProcessing {
*/
boolean isAsyncStateProcessingEnabled();
- /**
- * Set key context for async state processing.
- *
- * @param record the record.
- * @param keySelector the key selector to select a key from record.
- * @param <T> the type of the record.
- */
- <T> void setAsyncKeyedContextElement(StreamRecord<T> record,
KeySelector<T, ?> keySelector)
- throws Exception;
-
- /** A callback that will be triggered after an element finishes {@code
processElement}. */
- void postProcessElement();
Review Comment:
Well, I think the current commits are able to better demonstrate the
evolving of interfaces (introduce and split). But I'll refine this. Thanks for
your suggestion.
--
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: issues-unsubscr...@flink.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
