MarkLogic Connector for Hadoop 1.1-3

com.marklogic.mapreduce
Class ZipEntryInputStream

java.lang.Object
  extended by java.io.InputStream
      extended by com.marklogic.mapreduce.ZipEntryInputStream
All Implemented Interfaces:
Closeable

public class ZipEntryInputStream
extends InputStream

ZipEntryInputStream is a wrapper class of ZipInputStream to interface with XCC so that the zip entries can be read sequentially.


Field Summary
static org.apache.commons.logging.Log LOG
           
 
Constructor Summary
ZipEntryInputStream(ZipInputStream zipIn, String fileName)
           
 
Method Summary
 void close()
           
 void closeZipInputStream()
           
 boolean hasNext()
           
 int read()
           
 int read(byte[] buf)
           
 int read(byte[] b, int off, int len)
           
 
Methods inherited from class java.io.InputStream
available, mark, markSupported, reset, skip
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

LOG

public static final org.apache.commons.logging.Log LOG
Constructor Detail

ZipEntryInputStream

public ZipEntryInputStream(ZipInputStream zipIn,
                           String fileName)
Method Detail

hasNext

public boolean hasNext()

read

public int read()
         throws IOException
Specified by:
read in class InputStream
Throws:
IOException

read

public int read(byte[] buf)
         throws IOException
Overrides:
read in class InputStream
Throws:
IOException

read

public int read(byte[] b,
                int off,
                int len)
         throws IOException
Overrides:
read in class InputStream
Throws:
IOException

close

public void close()
Specified by:
close in interface Closeable
Overrides:
close in class InputStream

closeZipInputStream

public void closeZipInputStream()
                         throws IOException
Throws:
IOException

MarkLogic Connector for Hadoop 1.1-3

Copyright © 2013 MarkLogic Corporation. All Rights Reserved.

Complete online documentation for MarkLogic Server, XQuery and related components may be found at developer.marklogic.com