This is an automated email from the ASF dual-hosted git repository.
morningman pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-doris.git
The following commit(s) were added to refs/heads/master by this push:
new 6934534 [fix](demo) scala.Function1 used in java about compiling
error:apply$mcVJ$sp(long)
6934534 is described below
commit 6934534155411fdc54d9690d41cdacc1bd0d293e
Author: Hengdong Gong <[email protected]>
AuthorDate: Sat Feb 12 15:59:41 2022 +0800
[fix](demo) scala.Function1 used in java about compiling
error:apply$mcVJ$sp(long)
Fix MyForeachPartitionFunction.java:xxx:xxx
java: org.apache.doris.demo.spark.demo.hdfs.MyForeachPartitionFunction is
not abstract and does not override abstract method apply$mcVJ$sp(long) in
scala.Function1
---
.../doris/demo/spark/demo/hdfs/MyForeachPartitionFunction.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git
a/samples/doris-demo/spark-demo/src/main/java/org/apache/doris/demo/spark/demo/hdfs/MyForeachPartitionFunction.java
b/samples/doris-demo/spark-demo/src/main/java/org/apache/doris/demo/spark/demo/hdfs/MyForeachPartitionFunction.java
index dfdfae8..8947a32 100644
---
a/samples/doris-demo/spark-demo/src/main/java/org/apache/doris/demo/spark/demo/hdfs/MyForeachPartitionFunction.java
+++
b/samples/doris-demo/spark-demo/src/main/java/org/apache/doris/demo/spark/demo/hdfs/MyForeachPartitionFunction.java
@@ -22,7 +22,7 @@ import com.alibaba.fastjson.JSONArray;
import lombok.extern.slf4j.Slf4j;
import org.apache.doris.demo.spark.util.DorisStreamLoad;
import org.apache.doris.demo.spark.vo.TestVo;
-import scala.Function1;
+import scala.runtime.AbstractFunction1;
import scala.collection.AbstractIterator;
import java.io.Serializable;
@@ -32,7 +32,7 @@ import java.util.Map;
@Slf4j
-public class MyForeachPartitionFunction implements Function1, Serializable {
+public class MyForeachPartitionFunction extends AbstractFunction1 implements
Serializable {
DorisStreamLoad dorisStreamLoad;
public MyForeachPartitionFunction(Map<String, Object> parameters) {
@@ -68,4 +68,4 @@ public class MyForeachPartitionFunction implements Function1,
Serializable {
public Function1 compose(Function1 g) {
return null;
}
-}
\ No newline at end of file
+}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
