Stack Overflow
Stack Overflow

Questions tagged [pelops]

A Java client library for accessing the Apache Cassandra database

27 questions
48
votes
5 answers

Cassandra Client Java API's

I have recently started working with Cassandra Database. Now I am in the process of evaluating which Cassandra client we should go forward with. I have seen various post on stackoverflow about which client to use for Cassandra but none has very…
arsenal
  • 23,366
  • 85
  • 225
  • 331
2
votes
0 answers

Bulk data upload in Cassandra using Pelops

I am using Pelops to work with Cassandra. I want to insert bulk data using mutator. When i insert around 20000 records it works fine but when I exceed the no of records it shows me a "Connection reset by peer: socket write error". I am writing the…
Tarun Nagpal
  • 964
  • 1
  • 9
  • 25
2
votes
1 answer

cassandra pelops exception "socket write error" once some data is inserted in batch in cassandra java

"org.apache.thrift.transport.TTransportException: java.net.SocketException: Software caused connection abort: socket write error" Getting this error after some batches are processed(i.e some data is inserted into the cassandra) m using pelops client…
samarth
  • 3,866
  • 7
  • 45
  • 60
2
votes
1 answer

Cassandra: How to delete UUIDs from the CLI?

Currently I'm using a client (Pelops) to insert UUIDs (both lexical and time) in to Cassandra. I haven't yet implemented a facility to remove them with Pelops; i'm testing and refining the insertion mechanism. As such, I would like to use the CLI to…
Kevin
  • 2,617
  • 29
  • 35
2
votes
1 answer

Efficient way to connect to Cassandra database using Pelops client

I am working on a project in which I need to use Cassandra Database. I have a sample program that will populate data into Cassandra database. I am using Pelops client for that. So now I am thinking of making a Singleton class for Cassandra database…
arsenal
  • 23,366
  • 85
  • 225
  • 331
2
votes
1 answer

java.lang.RuntimeException: exception while registering MBean, com.scale7.cassandra.pelops.pool:type=PooledNode-my_keyspace-localhost

I am working on a project in which I need to insert data into Cassandra database. So for that I am using Pelops client. I have a Multithreaded code which will insert into Cassandra database using Pelops client. And I am using ExecutorService for…
arsenal
  • 23,366
  • 85
  • 225
  • 331
2
votes
1 answer

Cassandra very slow doing sliceRange read, TimedOutException

Cassandra 1.0.12 We have a column family with name transactionRecords, its rowkey is "ApplicationName". The column family is used to record transactions, with namevalue pair like (UUID, transInfo). At the heavy load about 1.5K TPS, after 1 hour, the…
huican
  • 505
  • 1
  • 9
  • 21
2
votes
1 answer

Reinserting data after row deletion in cassandra using Pelops

I am trying to re-insert data for same row-key after deleting the row but they are not getting inserted. Neither any exception is thrown. I am using Pelops RowDeletor to delete the row data (Note that the row-key is still shown with no columns)…
user1668102
  • 149
  • 8
2
votes
1 answer

Cassandra - Reinserting deleted column

I was just running few simple tests (inserts and deletes) on column family I created. I observed that while new columns are getting inserted against a row key, but a column that has been recently deleted, does not get inserted. For…
user1668102
  • 149
  • 8
2
votes
3 answers

Why can't I insert this composite column name as Bytes into a CQL blob?

I have a CQL 3 CF CREATE TABLE entries ( id text, va text, ts bigint, idxc blob, PRIMARY KEY (id, va, ts) ); And with pelops I get for an insert of Bytes( [0, 4, 0, 0, 0, 4, 0, 0, 8, 0, 0, 1, 55, -56, -41, 6, 14, 0, 0, 16, 65, 50, 82, 97,…
Georg
  • 987
  • 8
  • 16
2
votes
1 answer

Java Pelops and Cassandra NoSQL DB: Can I Batch Delete Rows?

I'm trying to figure out how to batch delete rows in Cassandra DB using Pelops. Ideally, I could specify a KeyRange of rows that need to be deleted. That would work fine for my purposes. However, my (albeit brief) research is leading me to believe…
Cody S
  • 4,744
  • 8
  • 33
  • 64
1
vote
1 answer

Cassandra- Pelops :Getting No Such Method error while trying to insert data into cassandra

I am getting following error when m trying to insert data into cassandra using pelops api java.lang.NoSuchMethodError: org.apache.cassandra.thrift.Column.(Ljava/nio/ByteBuffer;Ljava/nio/ByteBuffer;J)V I am Using following…
samarth
  • 3,866
  • 7
  • 45
  • 60
1
vote
1 answer

Pelop deleteSubColumns => NullPointerException

This the code : Selector selector = Pelops.createSelector(CASSANDRA_POOL); Column column = selector.getSubColumnFromRow("Neighbours", user, neighbour, "Link_ID", CL_ONE); String linkID = new String(column.getValue()); Mutator mutator =…
dacanalr
  • 183
  • 2
  • 14
1
vote
1 answer

Counting columns, very slow CountQuery vs SliceQuery operations

I've written a "census" program to iterate through all the rows in a Column Family and within each row count the columns, recording the max value and row key. I've been spending more time with the Hector client but have written a Pelops client as…
libjack
  • 6,403
  • 2
  • 28
  • 36
1
vote
2 answers

Pelops - Catch Connection Error?

Is there a way to catch a connection error when using pelops in Java? I have the following code but for some reason, I'm not getting to my catch block. public static Boolean testDBConnection() throws PelopsException { try{ Cluster…
Kevin Mansel
  • 2,351
  • 1
  • 16
  • 15
1
2