1. 云栖社区>
  2. 全部标签>
  3. #Cassandra#
Cassandra

#Cassandra#

已有2人关注此标签

内容分类:
博客 | 问答 | 视频 | 资料 |

这个查询语句有时候可以查到 有时候又查不不到数据

这个查询语句有时候可以查到 有时候又查不不到数据CREATE TABLE IF NOT EXISTS api_stats ( app_name text, -- 目标应用…

Apache API Cassandra index Create

请教一个范围查询的问题

表结构 CREATE TABLE IF NOT EXISTS api_stats ( app_name text, -- 目标应用 -- 被其它应…

云栖社区 NOSQL SQL Apache API Cassandra index Create

spark根据df动态创建cassandra的表怎么搞?

spark根据df动态创建cassandra的表怎么搞?

spark Cassandra

spark从cassandra的某个表中取出部分列的数据怎么写? 这样的话岂不是只能先把全部数据加载出来才过滤?

spark从cassandra的某个表中取出部分列的数据怎么写? 这样的话岂不是只能先把全部数据加载出来才过滤?

spark Cassandra 社区大群

阿里云啥时候能有cassandra?

阿里云啥时候能有cassandra?

Cassandra

请教下大家,cassandra 集群中gossip信息交换相关问题 1. 集群发现是通过seeds节点主动去pull呢 还是节点各自固定频率交换信息; 2. 某个节点接受数据时,此时是主动push,还是按固定频率,节点pull获取信息。 这个我没有找到相关官方文档,求教于大家告知下

请教下大家,cassandra 集群中gossip信息交换相关问题 1. 集群发现是通过seeds节点主动去pull呢 还是节点各自固定频率交换信息; 2. 某个节点接受数据时,此时是主动push,还是按固定频率,节点pull获取信息。…

集群 Cassandra

我想问问大家都是直接基于 cassandra来做应用层服务么

我想问问大家都是直接基于 cassandra来做应用层服务么没有在加一层es 或者其他的什么

Cassandra

c*存储视频文件合适吗?

c*存储视频文件合适吗?

Cassandra 存储

《Cassandra 权威指南》第二版书评及访谈

《Cassandra 权威指南》第二版书评及访谈

Cassandra

Cassandra优势在哪里?

Cassandra优势在哪里?

Cassandra

cassandra的cql的基本命令

cassandra的cql的基本命令

Cassandra

从csv文件读取输入时,如何在Cassandra中插入数据时达到50k / s的吞吐量?

我的目标是增加Cassandra中版本控制数据的吞吐量。我使用了并发读取和写入,并且还增加了我的代码从文件中读取的块大小。我的机器是16GB,有8个核心,是的,我已经改变了Cassandra的yaml文件,进行了10k并发读写,当计时时,…

python LOG Cassandra session update csv

如何有效地将DataFrame转换为(列名称 - >列值列表)的Map

我想要实现的是,对于以下DataFrame: | FOO | BAR | BAZ || lorem | ipsum | dolor || sit | amet | dolor | | lorem | lorem | d…

spark DataFrame Cassandra list

Spark结构化流媒体从Cassandra中丰富

我使用结构化流式传输来自Kafka的数据 val df = spark .readStream .format("kafka") .option("kafka.bootstrap.servers", "localhost:9092") .…

spark string Cassandra url test schema uuid Group Commit bootstrap

Pyspark - 打印来自Kafka的消息

我建立了一个带有生产者和消费者的kafka系统,作为消息流式传输json文件的行。 使用pyspark,我需要分析不同流媒体窗口的数据。为此,我需要查看pyspark流式传输的数据......我该怎么做? 要运行代码,我使用了Yannae…

容器 spark Cassandra test

kafka conect cassandra source -error为十进制数据类型

我正在使用kafka connect cassandra source connector 1.0版本。我在cassandra表中有一个十进制数据类型列(价格),并将其作为json从源连接器写入kafka主题,它正在以类似的字符串格式写入十…

Json spark Cassandra source 数据类型

从Cassandra查询的数据不能再次在同一列上过滤(InvalidQueryException)

我试图从cassandra中按时间查询大块数据,然后使用spark数据集来一次处理较小的块,但是,应用程序失败并出现无效的查询异常: WARN 2018-11-22 13:16:54 org.apache.spark.scheduler…

java Apache spark exception Cassandra

播放Cassandra Netty Server空指针异常

我正在使用playframework与技术,如, spark = "2.3.1",akka = "2.4.7"hadoop = "2.7.7"spring = "4.2.6.RELEASE",spark-cassandra-connect…

java spark scala Server Cassandra Core netty thread SUN

flink在批量处理模式下会减少吗

根据flink流媒体文档: 窗口函数可以是ReduceFunction,FoldFunction或WindowFunction之一。前两个可以更有效地执行(参见State Size部分),因为Flink可以在每个窗口到达时递增地聚合它们的…

Go 函数 reduce Cassandra 存储 input flink

Apache Flink - 每小时聚合数据的每日汇总

我有一个窗口小时聚合的DataStream。 DataStream ds = ..... SingleOutputStreamOperator hourly = ds.keyBy(HourlyCountersAggregation.…

Apache Cassandra aggregate flink

2
GO