This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
import me.mcnelis.rudder.data.Feature; | |
import me.mcnelis.rudder.data.Label; | |
import me.mcnelis.rudder.data.Record; | |
public class Flower extends Record { | |
@Label | |
protected String species; | |
@Feature |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
from pycassa.pool import ConnectionPool | |
from pycassa.columnfamily import ColumnFamily | |
from pycassa.index import * | |
from pycassa.types import * | |
pool = ConnectionPool('keyspace',['localhost:9160'] | |
my_cf = ColumnFamily(pool,'my_cf') | |
def getRecords(colVal): | |
col_expr = create_index_expression('colName', colVal, EQ) |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
def py_insert(cf, listOfRecordsAsDict): | |
if cf not in columnfamilies: | |
columnfamilies[cf] = ColumnFamily(py_pool, cf) | |
try: | |
columnfamilies[cf].batch_insert(listOfRecordsAsDict) | |
except Exception, e: | |
logger.warning('Write failure. Waiting 1 second and trying again'); | |
time.wait(1) | |
try: |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
CREATE TABLE http_by_source ( | |
source text, | |
date timestamp, | |
column2 text, | |
column3 text, | |
column4 text, | |
value text, | |
PRIMARY KEY (source, date, column2, column3, column4) | |
) WITH COMPACT STORAGE AND | |
bloom_filter_fp_chance=0.010000 AND |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
ERROR 07:42:01,714 Exception in thread Thread[Thrift:26,5,main] | |
java.lang.AssertionError: [min(-1),max(-219851097003960625)] | |
at org.apache.cassandra.dht.Bounds.<init>(Bounds.java:41) | |
at org.apache.cassandra.dht.Bounds.<init>(Bounds.java:34) | |
at org.apache.cassandra.dht.Bounds.withNewRight(Bounds.java:121) | |
at org.apache.cassandra.service.StorageProxy.getRangeSlice(StorageProxy.java:1172) | |
at org.apache.cassandra.cql3.statements.SelectStatement.execute(SelectStatement.java:132) | |
at org.apache.cassandra.cql3.statements.SelectStatement.execute(SelectStatement.java:62) | |
at org.apache.cassandra.cql3.QueryProcessor.processStatement(QueryProcessor.java:132) | |
at org.apache.cassandra.cql3.QueryProcessor.process(QueryProcessor.java:143) |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
package com.emergingthreats.massif.etl; | |
import java.io.File; | |
import java.io.IOException; | |
import java.nio.ByteBuffer; | |
import org.apache.cassandra.db.marshal.AsciiType; | |
import org.apache.cassandra.dht.Murmur3Partitioner; | |
import org.apache.cassandra.io.sstable.SSTableSimpleUnsortedWriter; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
java.lang.AssertionError: [min(-1),max(-9124270273076175621)] | |
at org.apache.cassandra.dht.Bounds.<init>(Bounds.java:41) | |
at org.apache.cassandra.dht.Bounds.<init>(Bounds.java:34) | |
at org.apache.cassandra.dht.Bounds.withNewRight(Bounds.java:121) | |
at org.apache.cassandra.service.StorageProxy.getRangeSlice(StorageProxy.java:1172) | |
at org.apache.cassandra.cql3.statements.SelectStatement.execute(SelectStatement.java:124) | |
at org.apache.cassandra.cql3.statements.SelectStatement.execute(SelectStatement.java:56) | |
at org.apache.cassandra.cql3.QueryProcessor.processStatement(QueryProcessor.java:132) | |
at org.apache.cassandra.cql3.QueryProcessor.process(QueryProcessor.java:143) | |
at org.apache.cassandra.thrift.CassandraServer.execute_cql3_query(CassandraServer.java:1707) |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
DEBUG [Thrift:10] 2013-08-02 13:27:24,344 CustomTThreadPoolServer.java (line 209) Thrift transport error occurred during processing of message. | |
org.apache.thrift.transport.TTransportException | |
at org.apache.thrift.transport.TIOStreamTransport.read(TIOStreamTransport.java:132) | |
at org.apache.thrift.transport.TTransport.readAll(TTransport.java:84) | |
at org.apache.thrift.transport.TFramedTransport.readFrame(TFramedTransport.java:129) | |
at org.apache.thrift.transport.TFramedTransport.read(TFramedTransport.java:101) | |
at org.apache.thrift.transport.TTransport.readAll(TTransport.java:84) | |
at org.apache.thrift.protocol.TBinaryProtocol.readAll(TBinaryProtocol.java:378) | |
at org.apache.thrift.protocol.TBinaryProtocol.readI32(TBinaryProtocol.java:297) | |
at org.apache.thrift.protocol.TBinaryProtocol.readMessageBegin(TBinaryProtocol.java:204) |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
DEBUG 09:35:05,207 Thrift transport error occurred during processing of message. | |
org.apache.thrift.transport.TTransportException | |
at org.apache.thrift.transport.TIOStreamTransport.read(TIOStreamTransport.java:132) | |
at org.apache.thrift.transport.TTransport.readAll(TTransport.java:84) | |
at org.apache.thrift.transport.TFramedTransport.readFrame(TFramedTransport.java:129) | |
at org.apache.thrift.transport.TFramedTransport.read(TFramedTransport.java:101) | |
at org.apache.thrift.transport.TTransport.readAll(TTransport.java:84) | |
at org.apache.thrift.protocol.TBinaryProtocol.readAll(TBinaryProtocol.java:378) | |
at org.apache.thrift.protocol.TBinaryProtocol.readI32(TBinaryProtocol.java:297) | |
at org.apache.thrift.protocol.TBinaryProtocol.readMessageBegin(TBinaryProtocol.java:204) |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
FSReadError in /var/cassandra/data/et/http_request/ks-mycql3table-ic-1799-Data.db | |
at org.apache.cassandra.io.compress.CompressedRandomAccessReader.reBuffer(CompressedRandomAccessReader.java:93) | |
at org.apache.cassandra.io.util.RandomAccessReader.seek(RandomAccessReader.java:312) | |
at org.apache.cassandra.io.sstable.SSTableScanner.seekTo(SSTableScanner.java:98) | |
at org.apache.cassandra.db.RowIteratorFactory.getIterator(RowIteratorFactory.java:73) | |
at org.apache.cassandra.db.ColumnFamilyStore.getSequentialIterator(ColumnFamilyStore.java:1424) | |
at org.apache.cassandra.db.ColumnFamilyStore.getRangeSlice(ColumnFamilyStore.java:1476) | |
at org.apache.cassandra.service.RangeSliceVerbHandler.executeLocally(RangeSliceVerbHandler.java:46) | |
at org.apache.cassandra.service.RangeSliceVerbHandler.doVerb(RangeSliceVerbHandler.java:58) | |
at org.apache.cassandra.net.MessageDeliveryTask.run(MessageDeliveryTask.java:56) |
OlderNewer