Skip to content

Commit

Permalink
[fix](demo) scala.Function1 used in java about compiling error:apply$…
Browse files Browse the repository at this point in the history
…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
  • Loading branch information
gwdgithubnom authored Feb 12, 2022
1 parent ee26cd2 commit 6934534
Showing 1 changed file with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,7 @@
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;
Expand All @@ -32,7 +32,7 @@


@Slf4j
public class MyForeachPartitionFunction implements Function1, Serializable {
public class MyForeachPartitionFunction extends AbstractFunction1 implements Serializable {
DorisStreamLoad dorisStreamLoad;

public MyForeachPartitionFunction(Map<String, Object> parameters) {
Expand Down Expand Up @@ -68,4 +68,4 @@ public Function1 andThen(Function1 g) {
public Function1 compose(Function1 g) {
return null;
}
}
}

0 comments on commit 6934534

Please sign in to comment.