com.asakusafw.runtime.io.sequencefile

Class SequenceFileUtil

java.lang.Object

com.asakusafw.runtime.io.sequencefile.SequenceFileUtil

public final class SequenceFileUtil
extends Object

Accessors for SequenceFile.

Since:

0.2.5

Method Summary

Modifier and Type	Method and Description
static org.apache.hadoop.io.SequenceFile.Reader	openReader(InputStream in, org.apache.hadoop.fs.FileStatus status, org.apache.hadoop.conf.Configuration conf) Creates a new reader.
static org.apache.hadoop.io.SequenceFile.Reader	openReader(InputStream in, long length, org.apache.hadoop.conf.Configuration conf) Creates a new reader.
static org.apache.hadoop.io.SequenceFile.Writer	openWriter(OutputStream out, org.apache.hadoop.conf.Configuration conf, Class<?> keyClass, Class<?> valueClass, org.apache.hadoop.io.compress.CompressionCodec codec) Creates a new writer.

Methods inherited from class java.lang.Object

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

Method Detail

openReader

public static org.apache.hadoop.io.SequenceFile.Reader openReader(InputStream in,
                                                                  org.apache.hadoop.fs.FileStatus status,
                                                                  org.apache.hadoop.conf.Configuration conf)
                                                           throws IOException

Creates a new reader.

Parameters:

in - the source

status - target file status

conf - current configuration

Returns:

the created sequence file reader

Throws:

IOException - if failed to open the sequence file

IllegalArgumentException - if some parameters were null

openReader

public static org.apache.hadoop.io.SequenceFile.Reader openReader(InputStream in,
                                                                  long length,
                                                                  org.apache.hadoop.conf.Configuration conf)
                                                           throws IOException

Creates a new reader.

Parameters:

in - the source

length - the stream length

conf - current configuration

Returns:

the created sequence file reader

Throws:

IOException - if failed to open the sequence file

IllegalArgumentException - if some parameters were null

openWriter

public static org.apache.hadoop.io.SequenceFile.Writer openWriter(OutputStream out,
                                                                  org.apache.hadoop.conf.Configuration conf,
                                                                  Class<?> keyClass,
                                                                  Class<?> valueClass,
                                                                  org.apache.hadoop.io.compress.CompressionCodec codec)
                                                           throws IOException

Creates a new writer.

Parameters:

out - the drain

conf - current configuration

keyClass - the key type

valueClass - the value type

codec - the compression codec to block compression, or null to uncompressed

Returns:

the created sequence file writer

Throws:

IOException - if failed to create a sequence file

IllegalArgumentException - if some parameters were null