public class TextFileReader extends AbstractDataStreamReader implements DataStoreReader<java.lang.String>
TextFileReader は、生の HDFS ファイルから String を読み取ることができる DataStoreReader 実装です。AbstractDataStreamReader.ReaderHelper<T, V>| コンストラクターと説明 |
|---|
TextFileReader(org.apache.hadoop.conf.Configuration configuration, org.apache.hadoop.fs.Path basePath, CodecInfo codec) 新しいテキストファイルリーダーをインスタンス化します。 |
TextFileReader(org.apache.hadoop.conf.Configuration configuration, org.apache.hadoop.fs.Path basePath, CodecInfo codec, Split split) 新しいテキストファイルリーダーをインスタンス化します。 |
TextFileReader(org.apache.hadoop.conf.Configuration configuration, org.apache.hadoop.fs.Path basePath, CodecInfo codec, Split split, byte[] delimiter) 新しいテキストファイルリーダーをインスタンス化します。 |
| 修飾子と型 | メソッドと説明 |
|---|---|
void | close() |
java.lang.String | read() リーダーから次のエンティティを読み取ります。 |
getInputgetInputContext, 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 TextFileReader(org.apache.hadoop.conf.Configuration configuration,
org.apache.hadoop.fs.Path basePath,
CodecInfo codec)configuration - Hadoop の設定 basePath - HDFs パス codec - 圧縮コーデック情報 public TextFileReader(org.apache.hadoop.conf.Configuration configuration,
org.apache.hadoop.fs.Path basePath,
CodecInfo codec,
Split split)configuration - 構成 basePath - 基本パス codec - コーデック split - 入力分割 public void close()
throws java.io.IOExceptionjava.io.Closeable の close java.lang.AutoCloseable の close java.io.IOExceptionpublic java.lang.String read()
throws java.io.IOExceptionDataReaderDataReader<java.lang.String> の read nulljava.io.IOException - I/O エラーが発生した場合