org.apache.hadoop.io

类 MapFile.Writer

java.lang.Object

org.apache.hadoop.io.MapFile.Writer

所有已实现的接口:

Closeable, AutoCloseable

直接已知子类:

ArrayFile.Writer, BloomMapFile.Writer, SetFile.Writer

封闭类:

MapFile

public static class MapFile.Writer
extends Object
implements Closeable

Writes a new map.

构造器概要

构造器

构造器和说明
MapFile.Writer(Configuration conf, FileSystem fs, String dirName, Class<? extends WritableComparable> keyClass, Class valClass) Create the named map for keys of the named class.
MapFile.Writer(Configuration conf, FileSystem fs, String dirName, Class<? extends WritableComparable> keyClass, Class valClass, SequenceFile.CompressionType compress) Create the named map for keys of the named class.
MapFile.Writer(Configuration conf, FileSystem fs, String dirName, Class<? extends WritableComparable> keyClass, Class valClass, SequenceFile.CompressionType compress, CompressionCodec codec, Progressable progress) Create the named map for keys of the named class.
MapFile.Writer(Configuration conf, FileSystem fs, String dirName, Class<? extends WritableComparable> keyClass, Class valClass, SequenceFile.CompressionType compress, Progressable progress) Create the named map for keys of the named class.
MapFile.Writer(Configuration conf, FileSystem fs, String dirName, WritableComparator comparator, Class valClass) Create the named map using the named key comparator.
MapFile.Writer(Configuration conf, FileSystem fs, String dirName, WritableComparator comparator, Class valClass, SequenceFile.CompressionType compress) Create the named map using the named key comparator.
MapFile.Writer(Configuration conf, FileSystem fs, String dirName, WritableComparator comparator, Class valClass, SequenceFile.CompressionType compress, CompressionCodec codec, Progressable progress) Create the named map using the named key comparator.
MapFile.Writer(Configuration conf, FileSystem fs, String dirName, WritableComparator comparator, Class valClass, SequenceFile.CompressionType compress, Progressable progress) Create the named map using the named key comparator.

方法概要

方法

限定符和类型	方法和说明
void	append(WritableComparable key, Writable val) Append a key/value pair to the map.
void	close() Close the map.
int	getIndexInterval() The number of entries that are added before an index entry is added.
static void	setIndexInterval(Configuration conf, int interval) Sets the index interval and stores it in conf
void	setIndexInterval(int interval) Sets the index interval.

从类继承的方法 java.lang.Object

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

构造器详细资料

MapFile.Writer

public MapFile.Writer(Configuration conf,
              FileSystem fs,
              String dirName,
              Class<? extends WritableComparable> keyClass,
              Class valClass)
               throws IOException

Create the named map for keys of the named class.

抛出:

IOException

MapFile.Writer

public MapFile.Writer(Configuration conf,
              FileSystem fs,
              String dirName,
              Class<? extends WritableComparable> keyClass,
              Class valClass,
              SequenceFile.CompressionType compress,
              Progressable progress)
               throws IOException

Create the named map for keys of the named class.

抛出:

IOException

MapFile.Writer

public MapFile.Writer(Configuration conf,
              FileSystem fs,
              String dirName,
              Class<? extends WritableComparable> keyClass,
              Class valClass,
              SequenceFile.CompressionType compress,
              CompressionCodec codec,
              Progressable progress)
               throws IOException

Create the named map for keys of the named class.

抛出:

IOException

MapFile.Writer

public MapFile.Writer(Configuration conf,
              FileSystem fs,
              String dirName,
              Class<? extends WritableComparable> keyClass,
              Class valClass,
              SequenceFile.CompressionType compress)
               throws IOException

Create the named map for keys of the named class.

抛出:

IOException

MapFile.Writer

public MapFile.Writer(Configuration conf,
              FileSystem fs,
              String dirName,
              WritableComparator comparator,
              Class valClass)
               throws IOException

Create the named map using the named key comparator.

抛出:

IOException

MapFile.Writer

public MapFile.Writer(Configuration conf,
              FileSystem fs,
              String dirName,
              WritableComparator comparator,
              Class valClass,
              SequenceFile.CompressionType compress)
               throws IOException

Create the named map using the named key comparator.

抛出:

IOException

MapFile.Writer

public MapFile.Writer(Configuration conf,
              FileSystem fs,
              String dirName,
              WritableComparator comparator,
              Class valClass,
              SequenceFile.CompressionType compress,
              Progressable progress)
               throws IOException

Create the named map using the named key comparator.

抛出:

IOException

MapFile.Writer

public MapFile.Writer(Configuration conf,
              FileSystem fs,
              String dirName,
              WritableComparator comparator,
              Class valClass,
              SequenceFile.CompressionType compress,
              CompressionCodec codec,
              Progressable progress)
               throws IOException

Create the named map using the named key comparator.

抛出:

IOException

方法详细资料

getIndexInterval

public int getIndexInterval()

The number of entries that are added before an index entry is added.

setIndexInterval

public void setIndexInterval(int interval)

Sets the index interval.

另请参阅:

getIndexInterval()

setIndexInterval

public static void setIndexInterval(Configuration conf,
                    int interval)

Sets the index interval and stores it in conf

另请参阅:

getIndexInterval()

close

public void close()
           throws IOException

Close the map.

指定者:

close 在接口中 Closeable

指定者:

close 在接口中 AutoCloseable

抛出:

IOException

append

public void append(WritableComparable key,
          Writable val)
            throws IOException

Append a key/value pair to the map. The key must be greater or equal to the previous key added to the map.

抛出:

IOException