public class InputStoreObjectSupport extends StoreObjectSupport
Split
and InputContext
.Constructor and Description |
---|
InputStoreObjectSupport(org.apache.hadoop.conf.Configuration configuration,
org.apache.hadoop.fs.Path basePath,
CodecInfo codec)
Instantiates a new input store object support.
|
InputStoreObjectSupport(org.apache.hadoop.conf.Configuration configuration,
org.apache.hadoop.fs.Path basePath,
CodecInfo codec,
Split split)
Instantiates a new input store object support.
|
Modifier and Type | Method and Description |
---|---|
InputContext |
getInputContext()
Gets the input context.
|
Split |
getSplit()
Gets the input split.
|
doStart, doStop, flushTimeout, getCodec, getConfiguration, getPath, handleTimeout, isCompressed, onInit, resetIdleTimeout, setCloseTimeout, setFlushTimeout, setIdleTimeout
afterPropertiesSet, getBeanFactory, getPhase, getStoreEventPublisher, getTaskExecutor, getTaskScheduler, isAutoStartup, isRunning, setAutoStartup, setBeanFactory, setPhase, setStoreEventPublisher, setTaskExecutor, setTaskScheduler, start, stop, stop
public InputStoreObjectSupport(org.apache.hadoop.conf.Configuration configuration, org.apache.hadoop.fs.Path basePath, CodecInfo codec)
configuration
- the configurationbasePath
- the base pathcodec
- the codecpublic InputStoreObjectSupport(org.apache.hadoop.conf.Configuration configuration, org.apache.hadoop.fs.Path basePath, CodecInfo codec, Split split)
configuration
- the configurationbasePath
- the base pathcodec
- the codecsplit
- the input splitpublic Split getSplit()
public InputContext getInputContext()