cascading.tap.hadoop
Class ZipSplit

java.lang.Object
  extended by FileSplit
      extended by cascading.tap.hadoop.ZipSplit

public class ZipSplit
extends FileSplit

A section of an input file in zip format. Returned by ZipInputFormat.getSplits(JobConf , int) and passed to ZipInputFormat.getRecordReader(InputSplit , JobConf , Reporter).


Constructor Summary
ZipSplit(Path file, long length)
          Constructor ZipSplit creates a new ZipSplit instance.
ZipSplit(Path file, String entryPath, long length)
          Constructs a split from zip archive.
 
Method Summary
 String getEntryPath()
          The path of the file within the zip archive.
 void readFields(DataInput in)
           
 void write(DataOutput out)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ZipSplit

public ZipSplit(Path file,
                String entryPath,
                long length)
Constructs a split from zip archive.

Parameters:
file - the zip archive name
entryPath - the path of the file to be read within the zip archive.
length - the uncompressed size of the file within the zip archive.

ZipSplit

public ZipSplit(Path file,
                long length)
Constructor ZipSplit creates a new ZipSplit instance.

Parameters:
file - of type Path
length - of type long
Method Detail

getEntryPath

public String getEntryPath()
The path of the file within the zip archive.

Returns:
returns the path for this entry

write

public void write(DataOutput out)
           throws IOException
Throws:
IOException

readFields

public void readFields(DataInput in)
                throws IOException
Throws:
IOException


Copyright © 2007-2008 Concurrent, Inc. All Rights Reserved.