作者热门文章
- android - RelativeLayout 背景可绘制重叠内容
- android - 如何链接 cpufeatures lib 以获取 native android 库?
- java - OnItemClickListener 不起作用,但 OnLongItemClickListener 在自定义 ListView 中起作用
- java - Android 文件转字符串
我是 Cassandra 的新手。我正在使用 hadoop 使用 CqlOutputFormat 将数据批量加载到 cassandra 集群中。我无法在互联网上找到足够的示例来根据我的用例对其进行定制。
我专门用它来使用语句将数据插入集群,
insert into pinseries (pin, timeseries) values(?, ?)
我不确定 context.write() 应该是什么样子才能完成这项工作。似乎有足够的例子可以看出它应该如何用于更新语句(示例中的字数就可以)。但是有人能告诉我如何在插入模式下使用它吗?
最佳答案
CqlOutputFormat 使用的 CqlRecordWriter 不支持插入语句,仅支持更新语句,因此您需要使用更新来插入数据。沿着:
update pinseries set timeseries = ? where pin = ?
我假设 pin 是您的主键。
关于java - 将 CqlOutputFormat 用于 INSERT 语句,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/29126575/
我无法让我的 hadoop 作业运行。我收到以下异常: java.lang.RuntimeException: java.lang.ClassNotFoundException: org.apache
我是 Cassandra 的新手。我正在使用 hadoop 使用 CqlOutputFormat 将数据批量加载到 cassandra 集群中。我无法在互联网上找到足够的示例来根据我的用例对其进行定制
我是一名优秀的程序员,十分优秀!