[jira] [Created] (FLINK-22615) can't use test harness to test Scala UDF because of two versions of ProcessWindowFunction

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-22615) can't use test harness to test Scala UDF because of two versions of ProcessWindowFunction

Shang Yuanchun (Jira)
Zhenhao Li created FLINK-22615:
----------------------------------

             Summary: can't use test harness to test Scala UDF because of two versions of ProcessWindowFunction
                 Key: FLINK-22615
                 URL: https://issues.apache.org/jira/browse/FLINK-22615
             Project: Flink
          Issue Type: Improvement
            Reporter: Zhenhao Li


I'm trying to use `InternalSingleValueProcessWindowFunction` to test a UDF of class
```
org.apache.flink.streaming.api.scala.function.ProcessWindowFunction
```

But the constructor of `InternalSingleValueProcessWindowFunction` expect
```
org.apache.flink.streaming.api.functions.windowing.ProcessWindowFunction and
```

I'm wondering if it is possible to use a common abstraction for Java and Scala in those test utilities.




--
This message was sent by Atlassian Jira
(v8.3.4#803005)