riak

-1热度

1回答

我看到了Riak erlang和JS mapreduce的例子。但我是一个JAVA的家伙:)，喜欢用JAVA来做。此外，JS mapreduce已弃用。有没有办法做到这一点在Java中？请举个例子。我还在寻找一个Riak 2.0搜索的Java样本。在了Riak文档步骤看起来庞大的了Riak搜索。这可能看起来像是mapreduce和搜索的小菜谱。实际上可以通过一个例子来对它进行总结。发行我

1热度

2回答

datomic的自主，分布式存储选项的比较？

从我所了解到的Datomic的list of supported storage systems看来，以下内容可能都是自托管，并且是分布式。卡桑德拉了Riak Couchbase Infinispan的内存簇对于人谁不知道大多数的这些，什么是他们的差异，当谈到正在使用仅适用于Datomic。 Datomic不太关心存储系统的各项功能，因为它们仅用作“哑”键/值存储。那么，什么是重要的是我是

1热度

1回答

使用erlang riak客户端获取Riak的所有对象

假设我有“用户”存储区。我想获得从所有它的用户或至少10。正如我理解riakc_pb_socket：获得/ 3 第一个参数是PID，第二个是桶，第三 - 密钥。获取所有对象的一种方法是获取所有的键，然后遍历它们，但据我所知，这是效率低下的方法。还有别的办法吗？

0热度

1回答

Upia in Riak TS

有没有什么办法可以在RIAK TS中插入，就像在Mongodb中可以做的一样？我是否必须检查密钥是否存在，如果存在，请手动覆盖它？或者我可以假设插入将覆盖任何现有的密钥？

0热度

1回答

在Riak TS中删除表格

我正在尝试在RIAK TS中删除整个表格，但似乎没有任何效果。我已经在一个标准查询中使用了“drop table”（使用Python）： from riak import RiakClient client = RiakClient(host = '127.0.0.1') client.ts_query('ticks', 'DROP TABLE ticks') 但是这给了我一个DROP不明

0热度

1回答

如何在使用Docker时更改Riak TS的配置文件

我想在Docker集线器上使用Basho中的the docker-compose files运行本地集群。不过，我需要更改称为riak_kv.query.timeseries.max_quanta_span的量程配置变量（通常在/etc/riak/riak.conf中）。这在riak.conf中设置为= 5。如何在协调器和集群Docker节点中将其设置为更大的数字（以上docker-compose

1热度

1回答

了Riak二郎模块安装错误

我把主分支进行了Riak，二郎的客户端，并呼吁make ./rebar get-deps ==> meck (get-deps) ==> protobuffs (get-deps) ==> hamcrest (get-deps) ==> riak_pb (get-deps) ==> riak-erlang-client (get-deps) ./rebar compile ==> m

1热度

1回答

如何在pyspark上使用Spark Riak连接器？

我按照https://github.com/basho/spark-riak-connector的说明运行Spark 2.0.2-hadoop2.7。试图 - 1）pyspark --repositories https://dl.bintray.com/basho/data-platform --packages com.basho.riak:spark-riak-connector_2.11

2热度

1回答

如何解决使用Spark Riak连接器和pyspark构建RDD时的异常

我试图使用spark riak连接器并在执行非常简单的查询时发生异常。运行最新Riak TS 1.4，Spark 1.6.2，Hadoop 2.6，Scala 0.10（通过谷歌云数据计算机），spark-riak-collector com.basho.riak：spark-riak-connector_2.10：1.6.0 >>> import pyspark_riak >>> pyspa

1热度

1回答

了Riak正在打造bitcask桶类型

过期键的兄弟姐妹，我一直在使用multi后端存储，有以下配置的服务器了Riak： ... storage_backend = multi multi_backend.bitcask_mult.storage_backend = bitcask multi_backend.bitcask_mult.bitcask.expiry = 10s ... 我已经检查，步骤如下顺序正常工作。用钥