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, getPosition
findInitFiles, getOutputContext, getResolvedPath, initOutputContext, isAppendable, isFileWriteable, isOverwrite, isSyncable, onInit, renameFile, setAppendable, setFileNamingStrategy, setInWritingPrefix, setInWritingSuffix, setOverwrite, setRolloverStrategy, setSyncable, setWritePosition
doStart, doStop, flushTimeout, getCodec, getConfiguration, getPath, isCompressed, resetIdleTimeout, setCloseTimeout, setFlushTimeout, setIdleTimeout
afterPropertiesSet, getBeanFactory, getPhase, getStoreEventPublisher, getTaskExecutor, getTaskScheduler, isAutoStartup, isRunning, setAutoStartup, setBeanFactory, setPhase, setStoreEventPublisher, setTaskExecutor, setTaskScheduler, start, stop, stop
public 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.IOException
java.io.Flushable
の flush
java.io.IOException
public void hflush() throws java.io.IOException
java.io.IOException
public void close() throws java.io.IOException
java.io.Closeable
の close
java.lang.AutoCloseable
の close
java.io.IOException
public void write(java.lang.String entity) throws java.io.IOException
DataWriter
DataWriter<java.lang.String>
の write
entity
- 書き込むエンティティ java.io.IOException
- I/O エラーが発生した場合 protected void handleTimeout()
StoreObjectSupport
StoreObjectSupport
の handleTimeout