flink1.15 sink到cassandra pojo方式 怎么写

您可以使用以下代码将 Flink 1.15 中的数据以 POJO 方式写入 Cassandra：

DataStream<MyPojo> stream = ...; // 输入数据流
CassandraSink.addSink(stream)
    .setHost("127.0.0.1")
    .setPort(9042)
    .setKeyspace("my_keyspace")
    .setTable("my_table")
    .build();

其中，`MyPojo` 是您定义的 POJO 类，`setHost` 和 `setPort` 分别设置 Cassandra 的主机名和端口号，`setKeyspace` 和 `setTable` 分别设置要写入的 keyspace 和 table 名称。