public abstract class StoreObjectSupport extends LifecycleObjectSupport
| Constructor and Description | 
|---|
| StoreObjectSupport(org.apache.hadoop.conf.Configuration configuration,
                  org.apache.hadoop.fs.Path basePath,
                  CodecInfo codec)Instantiates a new abstract store support. | 
| Modifier and Type | Method and Description | 
|---|---|
| protected void | doStart()Subclasses may implement this method with the start behaviour. | 
| protected void | doStop()Subclasses may implement this method with the stop behaviour. | 
| CodecInfo | getCodec()Gets the codec. | 
| org.apache.hadoop.conf.Configuration | getConfiguration()Gets the configuration. | 
| org.apache.hadoop.fs.Path | getPath()Gets the path. | 
| protected void | handleIdleTimeout()Handle idle timeout. | 
| boolean | isCompressed()Checks if is compressed. | 
| protected void | onInit()Subclasses may implement this for initialization logic. | 
| void | resetIdleTimeout()Reset idle timeout. | 
| void | setIdleTimeout(long idleTimeout)Sets the idle timeout. | 
afterPropertiesSet, getBeanFactory, getPhase, getStoreEventPublisher, getTaskExecutor, getTaskScheduler, isAutoStartup, isRunning, setAutoStartup, setBeanFactory, setPhase, setStoreEventPublisher, setTaskExecutor, setTaskScheduler, start, stop, stoppublic StoreObjectSupport(org.apache.hadoop.conf.Configuration configuration,
                  org.apache.hadoop.fs.Path basePath,
                  CodecInfo codec)
configuration - the hadoop configurationbasePath - the hdfs pathcodec - the compression codec infoprotected void onInit()
               throws java.lang.Exception
LifecycleObjectSupportInitializingBean phase.
 Implementor should always call super method not to break initialization chain.onInit in class LifecycleObjectSupportjava.lang.Exceptionprotected void doStart()
LifecycleObjectSupportLifecycleObjectSupport.lifecycleLock.doStart in class LifecycleObjectSupportprotected void doStop()
LifecycleObjectSupportLifecycleObjectSupport.lifecycleLock.doStop in class LifecycleObjectSupportpublic org.apache.hadoop.conf.Configuration getConfiguration()
public org.apache.hadoop.fs.Path getPath()
public CodecInfo getCodec()
public boolean isCompressed()
public void setIdleTimeout(long idleTimeout)
idleTimeout - the new idle timeoutpublic void resetIdleTimeout()
protected void handleIdleTimeout()