public class OutputStreamWriter extends AbstractDataStreamWriter implements DataStoreWriter<byte[]>
OutputStreamWriter
は、byte[]
を生の HDF ファイルに書き込むことができる DataStoreWriter
実装です。DEFAULT_MAX_OPEN_ATTEMPTS
コンストラクターと説明 |
---|
OutputStreamWriter(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(byte[] entity) エンティティを書き込みます。 |
getOutput, getPosition, setMaxOpenAttempts
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 OutputStreamWriter(org.apache.hadoop.conf.Configuration configuration, org.apache.hadoop.fs.Path basePath, CodecInfo codec)
configuration
- 構成 basePath
- 基本パス 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(byte[] entity) throws java.io.IOException
DataWriter
DataWriter<byte[]>
の write
entity
- 書き込むエンティティ java.io.IOException
- I/O エラーが発生した場合 protected void handleTimeout()
StoreObjectSupport
StoreObjectSupport
の handleTimeout