Hi,
I have a column family as below:
(Wide row design)
CREATE TABLE clicks (hour text,adId int,itemId int,time timeuuid,PRIMARY
KEY((adId, hour), time, itemId)) WITH CLUSTERING ORDER BY (time DESC);
Now to query for a given Ad Id and specific 3 hours say 2015-01-07 11 to
2015-01-07 14, how do I
Thanks Ryan
2015-01-06 20:21 GMT+01:00 Ryan Svihla :
> If you look at the source there are some useful comments regarding those
> specifics
> https://github.com/apache/cassandra/blob/8d8fed52242c34b477d0384ba1d1ce3978efbbe8/src/java/org/apache/cassandra/db/DeletionTime.java
>
>
> /** * A timestam
On Wed, Jan 7, 2015 at 10:18 AM, Ajay wrote:
> Hi,
>
> I have a column family as below:
>
> (Wide row design)
> CREATE TABLE clicks (hour text,adId int,itemId int,time timeuuid,PRIMARY
> KEY((adId, hour), time, itemId)) WITH CLUSTERING ORDER BY (time DESC);
>
> Now to query for a given Ad Id and
Thanks.
Basically there are two access patterns:
1) For last 1 hour (or more if last batch failed for some reason), get the
clicks data for all Ads. But it seems not possible as Ad Id is part of
Partition key.
2) For last 1 hour (or more if last batch failed for some reason), get the
clicks data
HI All,
We are trying to integrate elasticsearch with Cassandra and as the river
plugin uses select * from any table it seems to be bad performance choice.
So i was thinking of inserting into elasticsearch using Cassandra trigger.
So i wanted your view does a Cassandra Trigger impacts the performa
Be very very careful not to perform blocking calls to ElasticSearch in your
trigger otherwise you will kill C* performance. The biggest danger of the
triggers in their current state is that they are on the write path.
In your trigger, you can try to push the mutation asynchronously to ES but
in th
really depends on your code for error handling, and since you're using
thrift it really depends on the client, if you're doing client side
timestamps then it's not related to time issues.
On Tue, Jan 6, 2015 at 8:19 PM, wrote:
> Hi,
>
> I found that in my function, both delete and update use th
Hi,
I have a single partition key that been nagging me because I am receiving
org.apache.cassandra.db.filter.TombstoneOverwhelmingException. After filing
https://issues.apache.org/jira/browse/CASSANDRA-8561 I managed to find the
partition key in question and which machine it was located on (by
When last I looked at Datastax Enterprise (DSE 3.0ish), it exhibits the
same problem that you highlight, no different than your good idea of
asynchronously pushing to ES.
Each Cassandra write was indexed independently by each server in the
replication group. If a node timed out or a mutation was
HI All,
What i intend to do is on every write i would push the code to
elasticsearch using the Trigger. I know it would impact the Cassandra write
but given that the WRITE is pretty performant on Cassandra would that lag
be a big one.
Also as per my information SOLR has limitation of using Nes
Something to start considering is the partition key (first part of your
primary key) drives your model more than anything. So if you're querying
for all of X your partition key should probably be X, but there are some
constraints to be mindful of.
The rest of replies inline
On Wed, Jan 7, 2015 at
@Ken So I actually support a lot of the DSE Search users and teach classes
on it, so as long as you're not dropping mutations you're in sync, and if
you're dropping mutations you're probably sized way too small anyway, and
once you run repair (which you should be doing anyway when dropping
mutation
Hi,
We have a Cassandra cluster with Keyspaces that were created using the
thrift api and thei names contain upper case letters.
We are trying to use the new Datastax driver (version 2.1.4, maven's latest
) but encountering some problems due to upper case handling.
Datastax provide this guidance
We noticed the same issue. From the cassandra-cli, it allows to use upper
case or mixed case Keyspace name but from cqlsh it auto converts to lower
case.
Thanks
Ajay
On Wed, Jan 7, 2015 at 9:44 PM, Harel Gliksman wrote:
> Hi,
>
> We have a Cassandra cluster with Keyspaces that were created usin
On Wed, Jan 7, 2015 at 5:40 AM, Asit KAUSHIK
wrote:
> We are trying to integrate elasticsearch with Cassandra and as the river
> plugin uses select * from any table it seems to be bad performance choice.
> So i was thinking of inserting into elasticsearch using Cassandra trigger.
> So i wanted yo
+1. Don't use triggers.
On Wed, Jan 7, 2015 at 10:49 AM, Robert Coli wrote:
> On Wed, Jan 7, 2015 at 5:40 AM, Asit KAUSHIK
> wrote:
>>
>> We are trying to integrate elasticsearch with Cassandra and as the river
>> plugin uses select * from any table it seems to be bad performance choice.
>> So
DSE does now have a queue to decouple Cassandra insert and Solr indexing.
It will block only when/if the queue is filled - you can configure the size
of the queue. So, to be clear, DSE no longer has the highlighted problem
mentioned for ES.
-- Jack Krupansky
On Wed, Jan 7, 2015 at 9:46 AM, Ken Ha
CQLSSTableWriter only accepts an INSERT or UPDATE statement. I'm wondering
whether make it accept DELETE statement.
I need to update my cassandra table with a lot of data everyday.
* I may need to delete a row (given the partition key)
* I may need to delete some columns. For example, there are 2
I set up two virtual data centers, one for analytics and one for REST
service. The analytics data center sits top on Hadoop cluster. I want to
bulk load my ETL results into the analytics data center so that the REST
service won't have the heavy load. I'm using CQLTableInputFormat in my
Spark Applic
Hi,
We have a 3 node cluster (on VM). Eg. host1, host2, host3. One of the VM
rebooted (host1) and when host1 came up it would see the others as down and
the others (host2 and host3) see it as down. So we restarted host2 and now
the ring seems fine(everybody sees everybody as up).
But now the clie
Hi Anand,
On 08/01/15 02:02, Anand Somani wrote:
Hi,
We have a 3 node cluster (on VM). Eg. host1, host2, host3. One of the VM
rebooted (host1) and when host1 came up it would see the others as down and the
others (host2 and host3) see it as down. So we restarted host2 and now the ring
seems fin
Thanks Ajay for your reply,
My problem is not with the cqlsh interface, but with the java Datastax
driver.
It seems that for cqlsh, one needs to simply quote names that contain upper
cases.
With the driver, I experience inconsistent handling of upper case. Either I
am doing something wrong, or the
22 matches
Mail list logo
