org.springframework.data.hadoop.store.support

Class InputStoreObjectSupport

java.lang.Object

org.springframework.data.hadoop.store.support.LifecycleObjectSupport

org.springframework.data.hadoop.store.support.StoreObjectSupport

org.springframework.data.hadoop.store.support.InputStoreObjectSupport

All Implemented Interfaces:

org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.InitializingBean, org.springframework.context.Lifecycle, org.springframework.context.Phased, org.springframework.context.SmartLifecycle

Direct Known Subclasses:

AbstractDataStreamReader

public class InputStoreObjectSupport
extends StoreObjectSupport

Base class for input readers sharing common functionality for Split and InputContext.

Author:

Janne Valkealahti

Constructor Summary

Constructors

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.

Method Summary

Methods

Modifier and Type	Method and Description
InputContext	getInputContext() Gets the input context.
Split	getSplit() Gets the input split.

Methods inherited from class org.springframework.data.hadoop.store.support.StoreObjectSupport

doStart, doStop, getCodec, getConfiguration, getPath, handleIdleTimeout, isCompressed, onInit, resetIdleTimeout, setIdleTimeout

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

InputStoreObjectSupport

public InputStoreObjectSupport(org.apache.hadoop.conf.Configuration configuration,
                       org.apache.hadoop.fs.Path basePath,
                       CodecInfo codec)

Instantiates a new input store object support.

Parameters:

configuration - the configuration

basePath - the base path

codec - the codec

InputStoreObjectSupport

public InputStoreObjectSupport(org.apache.hadoop.conf.Configuration configuration,
                       org.apache.hadoop.fs.Path basePath,
                       CodecInfo codec,
                       Split split)

Instantiates a new input store object support.

Parameters:

configuration - the configuration

basePath - the base path

codec - the codec

split - the input split

Method Detail

getSplit

public Split getSplit()

Gets the input split.

Returns:

the input split

getInputContext

public InputContext getInputContext()

Gets the input context.

Returns:

the input context