public abstract class AbstractDataStreamWriter extends OutputStoreObjectSupport
AbstractDataStreamWriter は、生の HDFS ファイルを含むストリームを処理する基本実装です。| 修飾子と型 | フィールドと説明 |
|---|---|
static int | DEFAULT_MAX_OPEN_ATTEMPTS |
| コンストラクターと説明 |
|---|
AbstractDataStreamWriter(org.apache.hadoop.conf.Configuration configuration, org.apache.hadoop.fs.Path basePath, CodecInfo codec) 新しい抽象データストリームライターをインスタンス化します。 |
| 修飾子と型 | メソッドと説明 |
|---|---|
protected StreamsHolder<java.io.OutputStream> | getOutput() 出力を取得します。 |
protected long | getPosition(StreamsHolder<java.io.OutputStream> holder) 現在のストリーム書き込み位置を取得します。 |
void | setMaxOpenAttempts(int maxOpenAttempts) 出力ストリームに適したパスを見つけるための最大オープン試行回数を設定します。 |
findInitFiles, getOutputContext, getResolvedPath, initOutputContext, isAppendable, isFileWriteable, isOverwrite, isSyncable, onInit, renameFile, setAppendable, setFileNamingStrategy, setInWritingPrefix, setInWritingSuffix, setOverwrite, setRolloverStrategy, setSyncable, setWritePositiondoStart, doStop, flushTimeout, getCodec, getConfiguration, getPath, handleTimeout, isCompressed, resetIdleTimeout, setCloseTimeout, setFlushTimeout, setIdleTimeoutafterPropertiesSet, getBeanFactory, getPhase, getStoreEventPublisher, getTaskExecutor, getTaskScheduler, isAutoStartup, isRunning, setAutoStartup, setBeanFactory, setPhase, setStoreEventPublisher, setTaskExecutor, setTaskScheduler, start, stop, stoppublic static final int DEFAULT_MAX_OPEN_ATTEMPTS
public AbstractDataStreamWriter(org.apache.hadoop.conf.Configuration configuration,
org.apache.hadoop.fs.Path basePath,
CodecInfo codec)configuration - Hadoop の設定 basePath - HDFs パス codec - 圧縮コーデック情報 public void setMaxOpenAttempts(int maxOpenAttempts)
maxOpenAttempts - 新しい最大オープン試行回数 protected StreamsHolder<java.io.OutputStream> getOutput() throws java.io.IOException
java.io.IOException - I/O 例外が発生したことを通知します。protected long getPosition(StreamsHolder<java.io.OutputStream> holder) throws java.io.IOException
holder - 出力ストリームのホルダー java.io.IOException - I/O 例外が発生したことを通知します。