edu.sc.seis.crocus.importer

Class AbstractImporter

java.lang.Object

edu.sc.seis.crocus.importer.AbstractImporter

Direct Known Subclasses:

EarthwormImporterImport, GapScanReloader, RabbitMQImporter, SeedLinkImport

public abstract class AbstractImporter
extends java.lang.Object

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
AbstractImporter(java.lang.String[] args)

Method Summary

Modifier and Type	Method and Description
static java.lang.Integer	extractTTL(java.util.Properties props, java.lang.String keyPrefix)
CrocusWriter	getCrocus()
abstract java.lang.String	getPropPrefix()
static CrocusWriter	setUpCrocusWriter(com.netflix.astyanax.AstyanaxContext<com.netflix.astyanax.Keyspace> context, java.lang.Integer ttl)
void	start()
static void	startCrocusWriter(CrocusWriter crocus)
static void	startImporter(java.lang.String propPrefix, java.lang.Runnable importer)

Methods inherited from class java.lang.Object

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

Field Detail

TTL_PROP_NAME

public static final java.lang.String TTL_PROP_NAME

See Also:

Constant Field Values

Constructor Detail

AbstractImporter

public AbstractImporter(java.lang.String[] args)
                 throws java.lang.Exception

Throws:

java.lang.Exception

Method Detail

getPropPrefix

public abstract java.lang.String getPropPrefix()

setUpCrocusWriter

public static CrocusWriter setUpCrocusWriter(com.netflix.astyanax.AstyanaxContext<com.netflix.astyanax.Keyspace> context,
                                             java.lang.Integer ttl)
                                      throws java.lang.Exception

Throws:

java.lang.Exception

extractTTL

public static java.lang.Integer extractTTL(java.util.Properties props,
                                           java.lang.String keyPrefix)

start

public void start()
           throws java.lang.Exception

Throws:

java.lang.Exception

startImporter

public static void startImporter(java.lang.String propPrefix,
                                 java.lang.Runnable importer)
                          throws java.lang.Exception

Throws:

java.lang.Exception

startCrocusWriter

public static void startCrocusWriter(CrocusWriter crocus)
                              throws java.lang.Exception

Throws:

java.lang.Exception

getCrocus

public CrocusWriter getCrocus()