如何在Scala中定义映射器，以flink中的Cassandra水槽？

Question

从

CassandraSink.addSink(result)
        .setHost("127.0.0.1")
        .setMapperOptions(() -> new Mapper.Option[]{Mapper.Option.saveNullFields(true)})
        .build();

flink docs 。如何

.setMapperOptions(() -> new Mapper.Option[]{Mapper.Option.saveNullFields(true)}) 

翻译成Scala？

映射器来自 com.datastax.driver.mapping.mapper

Answer 1

您引用的映射器API来自Cassandra Java驱动程序，因此仅在Java中可用。干杯!