public abstract class StoreObjectSupport extends LifecycleObjectSupport
| Constructor and Description |
|---|
StoreObjectSupport(Configuration configuration,
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.
|
Configuration |
getConfiguration()
Gets the configuration.
|
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(Configuration configuration, Path basePath, CodecInfo codec)
configuration - the hadoop configurationbasePath - the hdfs pathcodec - the compression codec infoprotected void onInit()
throws Exception
LifecycleObjectSupportInitializingBean phase.
Implementor should always call super method not to break initialization chain.onInit in class LifecycleObjectSupportExceptionprotected void doStart()
LifecycleObjectSupportLifecycleObjectSupport.lifecycleLock.doStart in class LifecycleObjectSupportprotected void doStop()
LifecycleObjectSupportLifecycleObjectSupport.lifecycleLock.doStop in class LifecycleObjectSupportpublic Configuration getConfiguration()
public Path getPath()
public CodecInfo getCodec()
public boolean isCompressed()
public void setIdleTimeout(long idleTimeout)
idleTimeout - the new idle timeoutpublic void resetIdleTimeout()
protected void handleIdleTimeout()