- 如果您觉得本站非常有看点，那么赶紧使用Ctrl+D 收藏吧
当正常在Flink的DataStream外部进行连接时，是否有人遇到过从Flink作业连接到Cassandra的任何问题？
Session session = clusterBuilder.getCluster().connect();
ResultSet resultSet = session.execute(resultStatement……继续阅读 »
我一直在努力建立一个从csv文件创建Datastream<Tuple3<Integer, java.sql.Time, Double>>的flink应用程序。该文件中的列（ID, dateTime and Result列）均为String，但应将其转换为Integer，java.sql.Time和Double。我想做的另一件事是用每天……继续阅读 »
