public class TextSequenceFileWriter extends AbstractSequenceFileWriter implements DataStoreWriter<java.lang.String>
TextSequenceFileWriter は、String を SequenceFile に書き込むことができる DataStoreWriter 実装です。| コンストラクターと説明 |
|---|
TextSequenceFileWriter(org.apache.hadoop.conf.Configuration configuration, org.apache.hadoop.fs.Path basePath, CodecInfo codec) 新しいテキストシーケンスファイルライターをインスタンス化します。 |
| 修飾子と型 | メソッドと説明 |
|---|---|
void | close() |
void | flush() |
protected void | handleTimeout() アイドルタイムアウトを処理します。 |
void | hflush() |
void | write(java.lang.String entity) エンティティを書き込みます。 |
getOutput, getPositionfindInitFiles, getOutputContext, getResolvedPath, initOutputContext, isAppendable, isFileWriteable, isOverwrite, isSyncable, onInit, renameFile, setAppendable, setFileNamingStrategy, setInWritingPrefix, setInWritingSuffix, setOverwrite, setRolloverStrategy, setSyncable, setWritePositiondoStart, doStop, flushTimeout, getCodec, getConfiguration, getPath, isCompressed, resetIdleTimeout, setCloseTimeout, setFlushTimeout, setIdleTimeoutafterPropertiesSet, getBeanFactory, getPhase, getStoreEventPublisher, getTaskExecutor, getTaskScheduler, isAutoStartup, isRunning, setAutoStartup, setBeanFactory, setPhase, setStoreEventPublisher, setTaskExecutor, setTaskScheduler, start, stop, stoppublic TextSequenceFileWriter(org.apache.hadoop.conf.Configuration configuration,
org.apache.hadoop.fs.Path basePath,
CodecInfo codec)configuration - Hadoop の設定 basePath - HDFs パス codec - 圧縮コーデック情報 public void flush()
throws java.io.IOExceptionjava.io.Flushable 内の flush java.io.IOExceptionpublic void hflush()
throws java.io.IOExceptionjava.io.IOExceptionpublic void close()
throws java.io.IOExceptionjava.io.Closeable 内の close java.lang.AutoCloseable 内の close java.io.IOExceptionpublic void write(java.lang.String entity)
throws java.io.IOExceptionDataWriterDataWriter<java.lang.String> 内の write entity - 書き込むエンティティ java.io.IOException - I/O エラーが発生した場合 protected void handleTimeout()
StoreObjectSupportStoreObjectSupport の handleTimeout