edu.sc.seis.crocus.cassandra

Class CrocusWriter

java.lang.Object

edu.sc.seis.crocus.cassandra.CrocusWriter

All Implemented Interfaces:

edu.sc.seis.cormorant.seismogram.BudLightWriter, java.lang.Runnable

public class CrocusWriter
extends java.lang.Object
implements edu.sc.seis.cormorant.seismogram.BudLightWriter

Field Summary

Fields

Modifier and Type	Field and Description
static byte[]	EMPTY_BYTES

Constructor Summary

Constructors

Constructor and Description
CrocusWriter(com.netflix.astyanax.AstyanaxContext<com.netflix.astyanax.Keyspace> context, edu.sc.seis.cormorant.seismogram.DataRecordQueue inQueue)
CrocusWriter(com.netflix.astyanax.AstyanaxContext<com.netflix.astyanax.Keyspace> context, edu.sc.seis.cormorant.seismogram.DataRecordQueue inQueue, java.lang.Integer timeToLiveSeconds, java.util.List<ImportProcessor> importProcessors)

Method Summary

Modifier and Type	Method and Description
com.netflix.astyanax.AstyanaxContext<com.netflix.astyanax.Keyspace>	getContext()
edu.sc.seis.cormorant.seismogram.DataRecordQueue	getQueue()
java.lang.Integer	getTimeToLiveSeconds()
protected void	outputToCassandra(NSLCDay rowKey, java.util.List<edu.sc.seis.seisFile.mseed.DataRecord> drList)
void	run()
void	sendNoDataToCache(edu.iris.Fissures.IfNetwork.ChannelId channel_id, edu.sc.seis.fissuresUtil.time.MicroSecondTimeRange range)
protected com.netflix.astyanax.connectionpool.OperationResult<java.lang.Void>	timedDataToCassandra(NSLCDay rowKey, java.util.List<TimedData> tdList)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

EMPTY_BYTES

public static final byte[] EMPTY_BYTES

Constructor Detail

CrocusWriter

public CrocusWriter(com.netflix.astyanax.AstyanaxContext<com.netflix.astyanax.Keyspace> context,
                    edu.sc.seis.cormorant.seismogram.DataRecordQueue inQueue)

CrocusWriter

public CrocusWriter(com.netflix.astyanax.AstyanaxContext<com.netflix.astyanax.Keyspace> context,
                    edu.sc.seis.cormorant.seismogram.DataRecordQueue inQueue,
                    java.lang.Integer timeToLiveSeconds,
                    java.util.List<ImportProcessor> importProcessors)

Parameters:

context -

inQueue -

maxPacketTime -

maxCoverageTime -

timeToLiveSeconds - seconds before data inserted is automatically deleted, null means never delete

Method Detail

run

public void run()

Specified by:

run in interface java.lang.Runnable

getQueue

public edu.sc.seis.cormorant.seismogram.DataRecordQueue getQueue()

Specified by:

getQueue in interface edu.sc.seis.cormorant.seismogram.BudLightWriter

getTimeToLiveSeconds

public java.lang.Integer getTimeToLiveSeconds()

sendNoDataToCache

public void sendNoDataToCache(edu.iris.Fissures.IfNetwork.ChannelId channel_id,
                              edu.sc.seis.fissuresUtil.time.MicroSecondTimeRange range)

Specified by:

sendNoDataToCache in interface edu.sc.seis.cormorant.seismogram.BudLightWriter

outputToCassandra

protected void outputToCassandra(NSLCDay rowKey,
                                 java.util.List<edu.sc.seis.seisFile.mseed.DataRecord> drList)
                          throws java.io.IOException,
                                 com.netflix.astyanax.connectionpool.exceptions.ConnectionException,
                                 CrocusException

Throws:

java.io.IOException

com.netflix.astyanax.connectionpool.exceptions.ConnectionException

CrocusException

timedDataToCassandra

protected com.netflix.astyanax.connectionpool.OperationResult<java.lang.Void> timedDataToCassandra(NSLCDay rowKey,
                                                                                                   java.util.List<TimedData> tdList)
                                                                                            throws CrocusException,
                                                                                                   java.io.IOException,
                                                                                                   com.netflix.astyanax.connectionpool.exceptions.ConnectionException

Throws:

CrocusException

java.io.IOException

com.netflix.astyanax.connectionpool.exceptions.ConnectionException

getContext

public com.netflix.astyanax.AstyanaxContext<com.netflix.astyanax.Keyspace> getContext()