org.apache.hadoop.hdfs.client

クラス HdfsDataOutputStream

java.lang.Object

java.io.OutputStream

java.io.FilterOutputStream

java.io.DataOutputStream

org.apache.hadoop.fs.FSDataOutputStream

org.apache.hadoop.hdfs.client.HdfsDataOutputStream

すべての実装されたインタフェース:

Closeable, DataOutput, Flushable, AutoCloseable, CanSetDropBehind, Syncable

@InterfaceAudience.Public
 @InterfaceStability.Evolving
public class HdfsDataOutputStream
extends FSDataOutputStream

The Hdfs implementation of FSDataOutputStream.

フィールドのサマリー

クラスから継承されたフィールド java.io.DataOutputStream

written

クラスから継承されたフィールド java.io.FilterOutputStream

out

コンストラクタのサマリー

コンストラクタ

コンストラクタと説明
HdfsDataOutputStream(org.apache.hadoop.crypto.CryptoOutputStream out, org.apache.hadoop.fs.FileSystem.Statistics stats)
HdfsDataOutputStream(org.apache.hadoop.crypto.CryptoOutputStream out, org.apache.hadoop.fs.FileSystem.Statistics stats, long startPosition)
HdfsDataOutputStream(org.apache.hadoop.hdfs.DFSOutputStream out, org.apache.hadoop.fs.FileSystem.Statistics stats)
HdfsDataOutputStream(org.apache.hadoop.hdfs.DFSOutputStream out, org.apache.hadoop.fs.FileSystem.Statistics stats, long startPosition)

メソッドのサマリー

修飾子とタイプ	メソッドと説明
int	getCurrentBlockReplication() Get the actual number of replicas of the current block.
void	hsync(EnumSet<org.apache.hadoop.hdfs.client.HdfsDataOutputStream.SyncFlag> syncFlags) Sync buffered data to DataNodes (flush to disk devices).

クラスから継承されたメソッド org.apache.hadoop.fs.FSDataOutputStream

close, getPos, hflush, hsync, setDropBehind

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

flush, size, write, write, writeBoolean, writeByte, writeBytes, writeChar, writeChars, writeDouble, writeFloat, writeInt, writeLong, writeShort, writeUTF

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

write

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

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

インタフェースから継承されたメソッド java.io.DataOutput

write

コンストラクタの詳細

HdfsDataOutputStream

public HdfsDataOutputStream(org.apache.hadoop.hdfs.DFSOutputStream out,
                            org.apache.hadoop.fs.FileSystem.Statistics stats,
                            long startPosition)
                     throws IOException

例外:

IOException

HdfsDataOutputStream

public HdfsDataOutputStream(org.apache.hadoop.hdfs.DFSOutputStream out,
                            org.apache.hadoop.fs.FileSystem.Statistics stats)
                     throws IOException

例外:

IOException

HdfsDataOutputStream

public HdfsDataOutputStream(org.apache.hadoop.crypto.CryptoOutputStream out,
                            org.apache.hadoop.fs.FileSystem.Statistics stats,
                            long startPosition)
                     throws IOException

例外:

IOException

HdfsDataOutputStream

public HdfsDataOutputStream(org.apache.hadoop.crypto.CryptoOutputStream out,
                            org.apache.hadoop.fs.FileSystem.Statistics stats)
                     throws IOException

例外:

IOException

メソッドの詳細

getCurrentBlockReplication

public int getCurrentBlockReplication()
                               throws IOException

Get the actual number of replicas of the current block. This can be different from the designated replication factor of the file because the namenode does not maintain replication for the blocks which are currently being written to. Depending on the configuration, the client may continue to write to a block even if a few datanodes in the write pipeline have failed, or the client may add a new datanodes once a datanode has failed.

戻り値:

the number of valid replicas of the current block

例外:

IOException

hsync

public void hsync(EnumSet<org.apache.hadoop.hdfs.client.HdfsDataOutputStream.SyncFlag> syncFlags)
           throws IOException

Sync buffered data to DataNodes (flush to disk devices).

パラメータ:

syncFlags - Indicate the detailed semantic and actions of the hsync.

例外:

IOException

関連項目:

FSDataOutputStream.hsync()