首页 文章

Cassandra用Java保存文件中的数据

提问于
浏览
1

我通过materiliazed视图使用Java存储数据到Cassandra,但我遇到了一个问题 . 问题是它不会将数据保存到Cassandra数据库 . 我收到了这个错误 .

No columns are defined for Materialized View other than primary key

REATE MATERIALIZED VIEW IF NOT iSISTS sensorkeyspace.maxtable AS select sensor_id,来自sensorkeyspace.sensortable的湿度(湿度不为空)PRIMARY KEY(sensor_id)线程中的异常“main”com.datastax.driver.core.exceptions.InvalidQueryException:No在com.datastax.driver.core.exceptions.InvalidQueryException.copy(InvalidQueryException.java:50)的com.datastax.driver.core.DriverThrowables.propagateCause(DriverThrowables.java:37)中为主键以外的物化视图定义了列 . at com.datastax.driver.core.DefaultResultSetFuture.getUninterruptibly(DefaultResultSetFuture.java:245)at com.datastax.driver.core.AbstractSession.execute(AbstractSession.java:64)at com.datastax.driver.core.AbstractSession.execute (AbstractSession.java:39)在sparkproject.SparkApp.main(SparkApp.java:41)引起:com.datastax.driver.core.exceptions.InvalidQueryException:没有为com.datastax上的主键以外的物化视图定义列.driver.core.Responses $埃罗r.asException(Responses.java:136)at com.datastax.driver.core.DefaultResultSetFuture.onSet(DefaultResultSetFuture.java:179)at com.datastax.driver.core.RequestHandler.setFinalResult(RequestHandler.java:174)at com .datastax.driver.core.RequestHandler.access $ 2600(RequestHandler.java:43)at com.datastax.driver.core.RequestHandler $ SpeculativeExecution.setFinalResult(RequestHandler.java:793)at com.datastax.driver.core.RequestHandler $ ComulativeExecution.onSet(RequestHandler.java:627)at com.datastax.driver.core.Connection $ Dispatcher.channelRead0(Connection.java:1012)at com.datastax.driver.core.Connection $ Dispatcher.channelRead0(Connection.java: 935)位于io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:342)的io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105)at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java) :328)

1 回答

  • 2

    看起来您正在使用与主表相同的主键创建实例化视图 . 请检查MV定义

相关问题