标签: nosql

我使用了两个NOSQL数据库MongoDB和Neo4j来处理相同的信息.我想使用第一个和第二个db来比较性能.我在这个问题上谈到了MongoDB 的问题:执行时间millis总是等于0.所以我在我的集​​合中添加了大约250个文档但没有任何成功:

> db.team.find({common_name:"Milan"},{_id:0, "stadium.name":1}).explain("executionStats")

{
        "queryPlanner" : {
                "plannerVersion" : 1,
                "namespace" : "Progettino.team",
                "indexFilterSet" : false,
                "parsedQuery" : {
                        "common_name" : {
                                "$eq" : "Milan"
                        }
                },
                "winningPlan" : {
                        "stage" : "PROJECTION",
                        "transformBy" : {
                                "_id" : 0,
                                "stadium.name" : 1
                        },
                        "inputStage" : {
                                "stage" : "COLLSCAN",
                                "filter" : {
                                        "common_name" : {
                                                "$eq" : "Milan"
                                        }
                                },
                                "direction" : "forward"
                        }
                },
                "rejectedPlans" : [ ]
        },
        "executionStats" …

我们可以仅使用全局二级索引来更新dynamodb项目吗？

$response = $dynamodbClient->updateItem(array(
            'TableName' => 'feed',
            'Key' => array(
                'feed_guid'      => array('S' => 'ac1e9683832ad2923f0bd84b91f34381'),
                'created_date'   => array('N' => '1439295833'),
            ),
            "ExpressionAttributeValues" =>  array (
                    ":val1" => array('N' => '1')
                ) ,
            "UpdateExpression" => $updateExpression,  
            'ReturnValues' => 'ALL_NEW'
        ));

在上面的代码中，我想替换关键部分并使用全局二级索引（即user_id）更新项目。

在LokiJS中,我尝试了一个非常简单的查询(我假设是AND):

var dbRes = recsCol.find({'format':format, 'cardId':-1});

插入一些数据后

recsCol.insert({format:format, cardId:id, recCardId:key, amount:item[key]});

不包含-1的cardId.

查询仍会产生结果.这是预期的行为吗？如果是这样,我怎样才能使字段完全匹配,以便在这种情况下我不会得到结果？

我是HBase的新手.目前我正在使用hortonworks沙箱hdp2.在研究Hbase时,我遇到了一些问题.

1. hbase在哪里存储数据？

2. 如果它存储在HDFS上,那么它如何执行更新操作,因为hdfs 写入一次并多次读取

我想知道如何在neo4j中具有不同属性值的特定两个节点之间创建多个关系。

例如在下面的图片中，“超级用户”和“数据分类”是不同的节点，我想要像所示图片那样的关系。

我试图在mongo中创建一个deleteAll方法，在其中我可以一次性删除多个记录，为该方法提供要删除的对象ID列表，如下所示

protected virtual  DeleteResult DeleteAll(List<ObjectId> listId, WriteConcern concern = null)
        {
            return MongoCollection
                .DeleteManyAsync(ItemWithListOfId(listId))
                    .Result;
        }

  protected FilterDefinition<T> ItemWithListOfId(List<ObjectId> id)
    {
        return Builders<T>.Filter.Eq("_id", id);            
    }

它没有给出错误，但也没有删除任何记录。任何人有帮助吗？

可以说我在JAVA中有以下模型

class Shape {
    String type;
    String color;
    String size;
}

并说我有以下基于上述模型的数据.

Triangle, Blue, Small
Triangle, Red, Large
Circle, Blue, Small
Circle, Blue, Medium
Square, Green, Medium
Star, Blue, Large

我想回答以下问题

Given the type Circle how many unique colors?
    Answer: 1
Given the type Circle how many unique sizes?
    Answer: 2

Given the color Blue how many unique shapes?
    Answer: 2
Given the color Blue how many unique sizes?
    Answer: 3

Given the size Small how many unique shapes?
    Answer: …

如何读取cassandra nodetool直方图百分位数和其他coulmns？

Percentile  SSTables     Write Latency      Read Latency    Partition Size        Cell Count
                              (micros)          (micros)           (bytes)                  
50%             1.00             14.24           4055.27               149                 2
75%            35.00             17.08          17436.92               149                 2
95%            35.00             24.60          74975.55               642                 2
98%            86.00             35.43         129557.75               770                 2
99%           103.00             51.01         186563.16               770                 2
Min             0.00              2.76             51.01               104                 2
Max           124.00       36904729.27       12359319.16               924                 2

我在Cassandra中使用了宽行模式.我的表定义如下:

CREATE TABLE usertopics (
    key text,
    topic text,
    score counter,
    PRIMARY KEY (key, topic)
)

我正在插入条目使用:

UPDATE usertopics SET score = score + ? WHERE key=? AND topic=?

这样如果密钥不存在,它将插入,如果它存在,它将更新.

我正在删除使用的条目:

Delete form usertopics where key in ?

但删除后,当我再次尝试更新时,它没有更新.它没有给出任何错误,但它也没有反映在db中.

当我截断表格时,它再次完美插入.我正在使用Datastax java驱动程序访问Cassandra.有什么建议？

使用cassandra对象映射器api想要进行批处理持久化.

对于单个对象,它工作正常.

Mapper<MyObj> mapper = new MappingManager(getSession()).mapper(MyObj.class);
mapper.save(myObj);

对于批量更新我试过这种方式,但理想情况下Cassandra认为我持久化列表所以它给出了异常,就像在List中找不到@Table注释,这是预期的行为

Mapper<List<MyObj>> mapper = new MappingManager(getSession()).mapper(List.class);
myObjList.add(myObj1)
myObjList.addd(myObj2)
mapper.save(myObjList);

有没有办法在使用批处理的cassandra中实现相同的功能？

注意:或者我可以通过使用for循环重复第一步来完成此操作,但我正在寻找批量插入@ObjectMapper.