AbstractDataStreamWriter (Spring for Apache Hadoop 2.5.0.RELEASE API)

java.lang.Object
- org.springframework.data.hadoop.store.support.LifecycleObjectSupport
- - org.springframework.data.hadoop.store.support.StoreObjectSupport
  - - org.springframework.data.hadoop.store.support.OutputStoreObjectSupport
    - - org.springframework.data.hadoop.store.output.AbstractDataStreamWriter

実装されたすべてのインターフェース:
org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.InitializingBean, org.springframework.context.Lifecycle, org.springframework.context.Phased, org.springframework.context.SmartLifecycle
既知の直属サブクラス
OutputStreamWriter, TextFileWriter
```
public abstract class AbstractDataStreamWriter
extends OutputStoreObjectSupport
```
AbstractDataStreamWriter は、生の HDFS ファイルを含むストリームを処理する基本実装です。
作成者:
Janne Valkealahti

フィールドのサマリー
フィールド
修飾子と型フィールドと説明
static int DEFAULT_MAX_OPEN_ATTEMPTS

フィールド
修飾子と型	フィールドと説明
`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)` 出力ストリームに適したパスを見つけるための最大オープン試行回数を設定します。

クラス org.springframework.data.hadoop.store.support.OutputStoreObjectSupport から継承されたメソッド
findInitFiles, getOutputContext, getResolvedPath, initOutputContext, isAppendable, isFileWriteable, isOverwrite, isSyncable, onInit, renameFile, setAppendable, setFileNamingStrategy, setInWritingPrefix, setInWritingSuffix, setOverwrite, setRolloverStrategy, setSyncable, setWritePosition

クラス org.springframework.data.hadoop.store.support.StoreObjectSupport から継承されたメソッド
doStart, doStop, flushTimeout, getCodec, getConfiguration, getPath, handleTimeout, isCompressed, resetIdleTimeout, setCloseTimeout, setFlushTimeout, setIdleTimeout

クラス org.springframework.data.hadoop.store.support.LifecycleObjectSupport から継承されたメソッド
afterPropertiesSet, getBeanFactory, getPhase, getStoreEventPublisher, getTaskExecutor, getTaskScheduler, isAutoStartup, isRunning, setAutoStartup, setBeanFactory, setPhase, setStoreEventPublisher, setTaskExecutor, setTaskScheduler, start, stop, stop

クラス java.lang.Object から継承されたメソッド
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- フィールドの詳細
  - DEFAULT_MAX_OPEN_ATTEMPTS
```
public static final int DEFAULT_MAX_OPEN_ATTEMPTS
```
    関連事項:
    定数フィールド値
- コンストラクターの詳細
  - AbstractDataStreamWriter
```
public AbstractDataStreamWriter(org.apache.hadoop.conf.Configuration configuration,
                        org.apache.hadoop.fs.Path basePath,
                        CodecInfo codec)
```
    新しい抽象データストリームライターをインスタンス化します。
    パラメーター:
    configuration - Hadoop の設定
    basePath - HDFs パス
    codec - 圧縮コーデック情報
- メソッドの詳細
  - setMaxOpenAttempts
```
public void setMaxOpenAttempts(int maxOpenAttempts)
```
    出力ストリームに適したパスを見つけるための最大オープン試行回数を設定します。正の値のみが許可され、これを 1 未満に設定しようとすると、値が自動的に 1 にリセットされます。
    パラメーター:
    maxOpenAttempts - 新しい最大オープン試行回数
  - getOutput
```
protected StreamsHolder<java.io.OutputStream> getOutput()
                                                 throws java.io.IOException
```
    出力を取得します。
    戻り値:
    出力
    例外:
    java.io.IOException - I/O 例外が発生したことを通知します。
  - getPosition
```
protected long getPosition(StreamsHolder<java.io.OutputStream> holder)
                    throws java.io.IOException
```
    現在のストリーム書き込み位置を取得します。
    パラメーター:
    holder - 出力ストリームのホルダー
    戻り値:
    位置
    例外:
    java.io.IOException - I/O 例外が発生したことを通知します。

クラス AbstractDataStreamWriter

フィールドのサマリー

コンストラクターの概要

メソッドのサマリー

クラス org.springframework.data.hadoop.store.support.OutputStoreObjectSupport から継承されたメソッド

クラス org.springframework.data.hadoop.store.support.StoreObjectSupport から継承されたメソッド

クラス org.springframework.data.hadoop.store.support.LifecycleObjectSupport から継承されたメソッド

クラス java.lang.Object から継承されたメソッド

フィールドの詳細

DEFAULT_MAX_OPEN_ATTEMPTS

コンストラクターの詳細

AbstractDataStreamWriter

メソッドの詳細

setMaxOpenAttempts

getOutput

getPosition