org.apache.accumulo.examples.simple.filedata
public class ChunkInputStream extends InputStream
ChunkInputFormat
to present input streams to a mapper.Modifier and Type | Field and Description |
---|---|
protected byte[] |
buf |
protected int |
count |
protected int |
currentChunk |
protected int |
currentChunkSize |
protected Key |
currentKey |
protected Set<org.apache.hadoop.io.Text> |
currentVis |
protected boolean |
gotEndMarker |
protected int |
pos |
protected PeekingIterator<Map.Entry<Key,Value>> |
source |
Constructor and Description |
---|
ChunkInputStream() |
ChunkInputStream(PeekingIterator<Map.Entry<Key,Value>> in) |
Modifier and Type | Method and Description |
---|---|
void |
clear() |
void |
close() |
Set<org.apache.hadoop.io.Text> |
getVisibilities() |
int |
read() |
int |
read(byte[] b,
int off,
int len) |
void |
setSource(PeekingIterator<Map.Entry<Key,Value>> in) |
available, mark, markSupported, read, reset, skip
protected PeekingIterator<Map.Entry<Key,Value>> source
protected Key currentKey
protected Set<org.apache.hadoop.io.Text> currentVis
protected int currentChunk
protected int currentChunkSize
protected boolean gotEndMarker
protected byte[] buf
protected int count
protected int pos
public ChunkInputStream()
public ChunkInputStream(PeekingIterator<Map.Entry<Key,Value>> in) throws IOException
IOException
public void setSource(PeekingIterator<Map.Entry<Key,Value>> in) throws IOException
IOException
public Set<org.apache.hadoop.io.Text> getVisibilities()
public int read() throws IOException
read
in class InputStream
IOException
public int read(byte[] b, int off, int len) throws IOException
read
in class InputStream
IOException
public void clear()
public void close() throws IOException
close
in interface Closeable
close
in class InputStream
IOException
Copyright © 2011-2015 The Apache Software Foundation. All Rights Reserved.