public class OneSecMinMaxCF extends java.lang.Object implements ImportProcessor
| Modifier and Type | Field and Description |
|---|---|
static java.lang.String |
CF_NAME |
| Constructor and Description |
|---|
OneSecMinMaxCF(com.netflix.astyanax.Keyspace keyspace,
java.lang.Integer timeToLiveSeconds) |
| Modifier and Type | Method and Description |
|---|---|
static void |
calcOneDataRecord(java.util.HashMap<java.lang.Long,OneSecMinMax> minMaxList,
NSLCDay nslcDay,
edu.sc.seis.seisFile.mseed.DataRecord dr) |
static com.netflix.astyanax.model.ColumnFamily<NSLCDay,java.lang.Long> |
getColFamilyDef() |
com.netflix.astyanax.Keyspace |
getKeyspace() |
java.lang.Integer |
getTimeToLiveSeconds() |
void |
processDataRecords(NSLCDay rowKey,
java.util.List<edu.sc.seis.seisFile.mseed.DataRecord> drList) |
void |
store(NSLCDay rowKey,
java.util.HashMap<java.lang.Long,OneSecMinMax> minMaxList) |
public static final java.lang.String CF_NAME
public OneSecMinMaxCF(com.netflix.astyanax.Keyspace keyspace,
java.lang.Integer timeToLiveSeconds)
public void processDataRecords(NSLCDay rowKey, java.util.List<edu.sc.seis.seisFile.mseed.DataRecord> drList) throws com.netflix.astyanax.connectionpool.exceptions.ConnectionException
processDataRecords in interface ImportProcessorcom.netflix.astyanax.connectionpool.exceptions.ConnectionExceptionpublic void store(NSLCDay rowKey, java.util.HashMap<java.lang.Long,OneSecMinMax> minMaxList) throws com.netflix.astyanax.connectionpool.exceptions.ConnectionException
com.netflix.astyanax.connectionpool.exceptions.ConnectionExceptionpublic static void calcOneDataRecord(java.util.HashMap<java.lang.Long,OneSecMinMax> minMaxList, NSLCDay nslcDay, edu.sc.seis.seisFile.mseed.DataRecord dr)
public com.netflix.astyanax.Keyspace getKeyspace()
public java.lang.Integer getTimeToLiveSeconds()
public static com.netflix.astyanax.model.ColumnFamily<NSLCDay,java.lang.Long> getColFamilyDef()