|
Spring for Apache Hadoop | ||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||
java.lang.Objectorg.springframework.data.hadoop.store.support.LifecycleObjectSupport
org.springframework.data.hadoop.store.support.StoreObjectSupport
public abstract class StoreObjectSupport
Base implementation of a store objects sharing a common functionality among store formats.
| Constructor Summary | |
|---|---|
StoreObjectSupport(org.apache.hadoop.conf.Configuration configuration,
org.apache.hadoop.fs.Path basePath,
CodecInfo codec)
Instantiates a new abstract store support. |
|
| Method Summary | |
|---|---|
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. |
| Methods inherited from class org.springframework.data.hadoop.store.support.LifecycleObjectSupport |
|---|
afterPropertiesSet, getBeanFactory, getPhase, getStoreEventPublisher, getTaskExecutor, getTaskScheduler, isAutoStartup, isRunning, setAutoStartup, setBeanFactory, setPhase, setStoreEventPublisher, setTaskExecutor, setTaskScheduler, start, stop, stop |
| Methods inherited from class java.lang.Object |
|---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| Constructor Detail |
|---|
public 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 info| Method Detail |
|---|
protected 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()
|
Spring for Apache Hadoop | ||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||