public class ChunkInputStream extends InputStream
ChunkOutputStream
This implementation is not thread-safe!
Bsed on Hector implementation for Cassandra.
https://github.com/rantav/hector/blob/master/core/src/main/java/me/prettyprint/cassandra/io/ChunkInputStream.javaConstructor and Description |
---|
ChunkInputStream(org.apache.hadoop.conf.Configuration conf,
byte[] tableName,
byte[] cf,
byte[] key) |
ChunkInputStream(org.apache.hadoop.conf.Configuration conf,
String tableName,
String cf,
byte[] key) |
Modifier and Type | Method and Description |
---|---|
boolean |
markSupported()
Not supported
|
int |
read() |
public ChunkInputStream(org.apache.hadoop.conf.Configuration conf, byte[] tableName, byte[] cf, byte[] key)
public int read() throws IOException
read
in class InputStream
IOException
public boolean markSupported()
markSupported
in class InputStream
Copyright © 2010-2012 The Apache Software Foundation. All Rights Reserved.