pnowojski commented on a change in pull request #9383: [FLINK-13248] [runtime] 
Adding processing of downstream messages in AsyncWaitOperator's wait loops
URL: https://github.com/apache/flink/pull/9383#discussion_r318419056
 
 

 ##########
 File path: 
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java
 ##########
 @@ -1194,6 +1197,37 @@ public ExecutionConfig getExecutionConfig() {
                return returnStream;
        }
 
+       /**
+        * Method for passing user defined operators along with the type 
information that will transform the DataStream.
+        *
+        * @param operatorName name of the operator, for logging purposes
+        * @param outTypeInfo the output type of the operator
+        * @param operatorFactory the factory for the operator.
+        * @param <R> type of the return stream
+        * @return the data stream constructed
+        */
+       @PublicEvolving
+       public <R> SingleOutputStreamOperator<R> transform(String operatorName, 
TypeInformation<R> outTypeInfo,
+                       OneInputStreamOperatorFactory<T, R> operatorFactory) {
 
 Review comment:
   It makes it less convenient for power users, but it's necessary for cleaner 
API and runtime code. I would mark as deprecated, because I would like to have 
at least flink built-in operators to move away from this old API in favour of 
`StreamOperatorFactory` as soon as possible.
   
   But ultimately we can merge it with or without `@Deprecated` note and 
question would be more towards the @aljoscha what does he prefer.

----------------------------------------------------------------
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.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


With regards,
Apache Git Services

Reply via email to