Re: Writing on Cassandra

[AndreaKinn]

Ok, this is my situation:

I have a stream of Tuple2<String, Tuple6&lt;String, String, Date, String,
String, Double>>

the cassandra code:

CassandraSink.addSink(stream)
                  .setQuery("INSERT INTO keyspace_local.values_by_sensors_users"
                + " (user, sensor, timestamp, json_ld, observed_value,
value)"
                + " VALUES (?, ?, ?, ?, ?, ?);")
                  .setClusterBuilder(new ClusterBuilder() {
                    @Override
                    public Cluster buildCluster(Cluster.Builder builder) {
                      return builder.addContactPoint("127.0.0.1").build();
                    }
                  })
                  .build();

the values to insert in VALUES clause are exactly the values of Tuple6. How
can I indicate that to my statement ?



--
View this message in context: 
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Writing-on-Cassandra-tp14744p14867.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at 
Nabble.com.