Reverting abstract method change

epiphanous · Mar 14, 2023 · d540213 · d540213
1 parent 48db359
commit d540213
Showing 1 changed file with 11 additions and 9 deletions.
diff --git a/src/main/scala/io/epiphanous/flinkrunner/model/sink/CassandraSinkConfig.scala b/src/main/scala/io/epiphanous/flinkrunner/model/sink/CassandraSinkConfig.scala
@@ -39,15 +39,17 @@ case class CassandraSinkConfig[ADT <: FlinkEvent](
 
   /** Don't convert to single abstract method...flink will complain
     */
-  val clusterBuilder: ClusterBuilder = (builder: Cluster.Builder) =>
-    builder
-      .addContactPoint(host)
-      .withPort(port)
-      .withoutJMXReporting()
-      .withCodecRegistry(
-        new CodecRegistry().register(InstantCodec.instance)
-      )
-      .build()
+  val clusterBuilder: ClusterBuilder = new ClusterBuilder {
+    override def buildCluster(builder: Cluster.Builder): Cluster =
+      builder
+        .addContactPoint(host)
+        .withPort(port)
+        .withoutJMXReporting()
+        .withCodecRegistry(
+          new CodecRegistry().register(InstantCodec.instance)
+        )
+        .build()
+  }
 
   def getSink[E <: ADT: TypeInformation](
       stream: DataStream[E]): DataStreamSink[E] = {