Uses of Class
org.apache.hadoop.hdfs.DFSOutputStream
Packages that use DFSOutputStream
Package
Description
This package provides the administrative APIs for HDFS.
-
Uses of DFSOutputStream in org.apache.hadoop.hdfs
Subclasses of DFSOutputStream in org.apache.hadoop.hdfsModifier and TypeClassDescriptionclassThis class supports writing files in striped layout and erasure coded format.Methods in org.apache.hadoop.hdfs that return DFSOutputStreamModifier and TypeMethodDescriptionDFSClient.create(String src, org.apache.hadoop.fs.permission.FsPermission permission, EnumSet<org.apache.hadoop.fs.CreateFlag> flag, boolean createParent, short replication, long blockSize, org.apache.hadoop.util.Progressable progress, int buffersize, org.apache.hadoop.fs.Options.ChecksumOpt checksumOpt) Create a new dfs file with the specified block replication with write-progress reporting and return an output stream for writing into the file.DFSClient.create(String src, org.apache.hadoop.fs.permission.FsPermission permission, EnumSet<org.apache.hadoop.fs.CreateFlag> flag, boolean createParent, short replication, long blockSize, org.apache.hadoop.util.Progressable progress, int buffersize, org.apache.hadoop.fs.Options.ChecksumOpt checksumOpt, InetSocketAddress[] favoredNodes) Same asDFSClient.create(String, FsPermission, EnumSet, boolean, short, long, Progressable, int, ChecksumOpt)with the addition of favoredNodes that is a hint to where the namenode should place the file blocks.DFSClient.create(String src, org.apache.hadoop.fs.permission.FsPermission permission, EnumSet<org.apache.hadoop.fs.CreateFlag> flag, boolean createParent, short replication, long blockSize, org.apache.hadoop.util.Progressable progress, int buffersize, org.apache.hadoop.fs.Options.ChecksumOpt checksumOpt, InetSocketAddress[] favoredNodes, String ecPolicyName) Same asDFSClient.create(String, FsPermission, EnumSet, boolean, short, long, Progressable, int, ChecksumOpt, InetSocketAddress[])with the addition of ecPolicyName that is used to specify a specific erasure coding policy instead of inheriting any policy from this new file's parent directory.DFSClient.create(String src, org.apache.hadoop.fs.permission.FsPermission permission, EnumSet<org.apache.hadoop.fs.CreateFlag> flag, boolean createParent, short replication, long blockSize, org.apache.hadoop.util.Progressable progress, int buffersize, org.apache.hadoop.fs.Options.ChecksumOpt checksumOpt, InetSocketAddress[] favoredNodes, String ecPolicyName, String storagePolicy) Same asDFSClient.create(String, FsPermission, EnumSet, boolean, short, long, Progressable, int, ChecksumOpt, InetSocketAddress[], String)with the storagePolicy that is used to specify a specific storage policy instead of inheriting any policy from this new file's parent directory.DFSClient.create(String src, org.apache.hadoop.fs.permission.FsPermission permission, EnumSet<org.apache.hadoop.fs.CreateFlag> flag, short replication, long blockSize, org.apache.hadoop.util.Progressable progress, int buffersize, org.apache.hadoop.fs.Options.ChecksumOpt checksumOpt) CallDFSClient.create(String, FsPermission, EnumSet, boolean, short, long, Progressable, int, ChecksumOpt)withcreateParentset to true.DFSClient.primitiveCreate(String src, org.apache.hadoop.fs.permission.FsPermission absPermission, EnumSet<org.apache.hadoop.fs.CreateFlag> flag, boolean createParent, short replication, long blockSize, org.apache.hadoop.util.Progressable progress, int buffersize, org.apache.hadoop.fs.Options.ChecksumOpt checksumOpt) Same as {DFSClient.create(String, FsPermission, EnumSet, short, long, Progressable, int, ChecksumOpt)except that the permission is absolute (ie has already been masked with umask.Methods in org.apache.hadoop.hdfs with parameters of type DFSOutputStreamModifier and TypeMethodDescriptionDFSClient.createWrappedOutputStream(DFSOutputStream dfsos, org.apache.hadoop.fs.FileSystem.Statistics statistics) Wraps the stream in a CryptoOutputStream if the underlying file is encrypted.DFSClient.createWrappedOutputStream(DFSOutputStream dfsos, org.apache.hadoop.fs.FileSystem.Statistics statistics, long startPos) Wraps the stream in a CryptoOutputStream if the underlying file is encrypted.voidDFSClient.putFileBeingWritten(String key, DFSOutputStream out) Put a file. -
Uses of DFSOutputStream in org.apache.hadoop.hdfs.client
Constructors in org.apache.hadoop.hdfs.client with parameters of type DFSOutputStreamModifierConstructorDescriptionHdfsDataOutputStream(DFSOutputStream out, org.apache.hadoop.fs.FileSystem.Statistics stats) HdfsDataOutputStream(DFSOutputStream out, org.apache.hadoop.fs.FileSystem.Statistics stats, long startPosition)