org.vertexium.accumulo.util

Class HdfsLargeDataStore

java.lang.Object

org.vertexium.accumulo.util.LimitOutputStream.LargeDataStore

org.vertexium.accumulo.util.HdfsLargeDataStore

public class HdfsLargeDataStore
extends LimitOutputStream.LargeDataStore

Constructor Summary

Constructors

Constructor and Description
HdfsLargeDataStore(org.apache.hadoop.fs.FileSystem fs, String dataDir, String rowKey, Property property)

Method Summary

Modifier and Type	Method and Description
protected org.apache.hadoop.fs.Path	createFileName()
OutputStream	createOutputStream()
org.apache.hadoop.fs.Path	getFullHdfsPath()
String	getRelativeFileName()

Methods inherited from class java.lang.Object

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

Constructor Detail

HdfsLargeDataStore

public HdfsLargeDataStore(org.apache.hadoop.fs.FileSystem fs,
                          String dataDir,
                          String rowKey,
                          Property property)

Method Detail

createOutputStream

public OutputStream createOutputStream()
                                throws IOException

Specified by:

createOutputStream in class LimitOutputStream.LargeDataStore

Throws:

IOException

createFileName

protected org.apache.hadoop.fs.Path createFileName()
                                            throws IOException

Throws:

IOException

getFullHdfsPath

public org.apache.hadoop.fs.Path getFullHdfsPath()

getRelativeFileName

public String getRelativeFileName()