edu.sc.seis.crocus.cassandra

Class ChannelYearDayWriter

java.lang.Object

edu.sc.seis.crocus.cassandra.ChannelYearDayWriter

All Implemented Interfaces:

ImportProcessor

public class ChannelYearDayWriter
extends java.lang.Object
implements ImportProcessor

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	CF_NAME

Constructor Summary

Constructors

Constructor and Description
ChannelYearDayWriter(com.netflix.astyanax.AstyanaxContext<com.netflix.astyanax.Keyspace> context, java.lang.Integer timeToLiveSeconds) YearDay for channels expires with give TTL + 86400 as yearday inserted at the beginning of the day should be valid at the end of the expiration day.

Method Summary

Modifier and Type	Method and Description
java.util.HashMap<NSLC,java.util.List<java.lang.Integer>>	bruteForceLoadAllChannels(com.netflix.astyanax.Keyspace keyspace)
static com.netflix.astyanax.model.ColumnFamily<NSLC,java.lang.Integer>	getColFamilyDef()
void	legacyLoad(com.netflix.astyanax.Keyspace keyspace)
static java.util.HashMap<NSLC,java.util.List<java.lang.Integer>>	loadFromCassandra(com.netflix.astyanax.Keyspace keyspace)
void	processDataRecords(NSLCDay rowKey, java.util.List<edu.sc.seis.seisFile.mseed.DataRecord> drList)

Methods inherited from class java.lang.Object

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

Field Detail

CF_NAME

public static final java.lang.String CF_NAME

See Also:

Constant Field Values

Constructor Detail

ChannelYearDayWriter

public ChannelYearDayWriter(com.netflix.astyanax.AstyanaxContext<com.netflix.astyanax.Keyspace> context,
                            java.lang.Integer timeToLiveSeconds)
                     throws java.lang.Exception

YearDay for channels expires with give TTL + 86400 as yearday inserted at the beginning of the day should be valid at the end of the expiration day.

Parameters:

context -

timeToLiveSeconds -

Throws:

java.lang.Exception

Method Detail

legacyLoad

public void legacyLoad(com.netflix.astyanax.Keyspace keyspace)
                throws java.lang.Exception

Throws:

java.lang.Exception

bruteForceLoadAllChannels

public java.util.HashMap<NSLC,java.util.List<java.lang.Integer>> bruteForceLoadAllChannels(com.netflix.astyanax.Keyspace keyspace)
                                                                                    throws java.lang.Exception

Throws:

java.lang.Exception

processDataRecords

public void processDataRecords(NSLCDay rowKey,
                               java.util.List<edu.sc.seis.seisFile.mseed.DataRecord> drList)
                        throws com.netflix.astyanax.connectionpool.exceptions.ConnectionException

Specified by:

processDataRecords in interface ImportProcessor

Throws:

com.netflix.astyanax.connectionpool.exceptions.ConnectionException

loadFromCassandra

public static java.util.HashMap<NSLC,java.util.List<java.lang.Integer>> loadFromCassandra(com.netflix.astyanax.Keyspace keyspace)
                                                                                   throws java.lang.Exception

Throws:

java.lang.Exception

getColFamilyDef

public static com.netflix.astyanax.model.ColumnFamily<NSLC,java.lang.Integer> getColFamilyDef()