public class AbstractDataStreamReader extends InputStoreObjectSupport
AbstractDataStreamReader は、生の HDFS ファイルを含むストリームを処理する基本実装です。| 修飾子と型 | クラスと説明 |
|---|---|
protected static class | AbstractDataStreamReader.ReaderHelper<T, V> 入力ストリームの操作の複雑さを隠すリーダーヘルパー。 |
| コンストラクターと説明 |
|---|
AbstractDataStreamReader(org.apache.hadoop.conf.Configuration configuration, org.apache.hadoop.fs.Path basePath, CodecInfo codec) 新しい抽象データストリームリーダーをインスタンス化します。 |
AbstractDataStreamReader(org.apache.hadoop.conf.Configuration configuration, org.apache.hadoop.fs.Path basePath, CodecInfo codec, Split split) 新しい抽象データストリームリーダーをインスタンス化します。 |
| 修飾子と型 | メソッドと説明 |
|---|---|
protected StreamsHolder<java.io.InputStream> | getInput() 入力ストリームをラップするホルダーを作成します。 |
getInputContext, getSplitdoStart, doStop, flushTimeout, getCodec, getConfiguration, getPath, handleTimeout, isCompressed, onInit, resetIdleTimeout, setCloseTimeout, setFlushTimeout, setIdleTimeoutafterPropertiesSet, getBeanFactory, getPhase, getStoreEventPublisher, getTaskExecutor, getTaskScheduler, isAutoStartup, isRunning, setAutoStartup, setBeanFactory, setPhase, setStoreEventPublisher, setTaskExecutor, setTaskScheduler, start, stop, stoppublic AbstractDataStreamReader(org.apache.hadoop.conf.Configuration configuration,
org.apache.hadoop.fs.Path basePath,
CodecInfo codec)configuration - Hadoop の設定 basePath - HDFs パス codec - 圧縮コーデック情報 protected StreamsHolder<java.io.InputStream> getInput() throws java.io.IOException
java.io.IOException - I/O 例外が発生したことを通知します。