Modifier and Type | Field and Description |
---|---|
protected int |
blockSize |
protected int |
bytesPerChecksum |
protected CacheConfig |
cacheConf |
protected ChecksumType |
checksumType |
protected KeyValue.KVComparator |
comparator |
protected Compression.Algorithm |
compression |
protected org.apache.hadoop.conf.Configuration |
conf |
protected HFileDataBlockEncoder |
encoder |
protected InetSocketAddress[] |
favoredNodes |
protected org.apache.hadoop.fs.FileSystem |
fs |
protected boolean |
includeMVCCReadpoint |
protected org.apache.hadoop.fs.FSDataOutputStream |
ostream |
protected org.apache.hadoop.fs.Path |
path |
Modifier and Type | Method and Description |
---|---|
HFile.Writer |
create() |
protected abstract HFile.Writer |
createWriter(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path path,
org.apache.hadoop.fs.FSDataOutputStream ostream,
int blockSize,
Compression.Algorithm compress,
HFileDataBlockEncoder dataBlockEncoder,
KeyValue.KVComparator comparator,
ChecksumType checksumType,
int bytesPerChecksum,
boolean includeMVCCReadpoint) |
HFile.WriterFactory |
includeMVCCReadpoint(boolean includeMVCCReadpoint) |
HFile.WriterFactory |
withBlockSize(int blockSize) |
HFile.WriterFactory |
withBytesPerChecksum(int bytesPerChecksum) |
HFile.WriterFactory |
withChecksumType(ChecksumType checksumType) |
HFile.WriterFactory |
withComparator(KeyValue.KVComparator comparator) |
HFile.WriterFactory |
withCompression(Compression.Algorithm compression) |
HFile.WriterFactory |
withCompression(String compressAlgo) |
HFile.WriterFactory |
withDataBlockEncoder(HFileDataBlockEncoder encoder) |
HFile.WriterFactory |
withFavoredNodes(InetSocketAddress[] favoredNodes) |
HFile.WriterFactory |
withOutputStream(org.apache.hadoop.fs.FSDataOutputStream ostream) |
HFile.WriterFactory |
withPath(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path path) |
protected final org.apache.hadoop.conf.Configuration conf
protected final CacheConfig cacheConf
protected org.apache.hadoop.fs.FileSystem fs
protected org.apache.hadoop.fs.Path path
protected org.apache.hadoop.fs.FSDataOutputStream ostream
protected int blockSize
protected Compression.Algorithm compression
protected HFileDataBlockEncoder encoder
protected KeyValue.KVComparator comparator
protected InetSocketAddress[] favoredNodes
protected ChecksumType checksumType
protected int bytesPerChecksum
protected boolean includeMVCCReadpoint
public HFile.WriterFactory withPath(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path path)
public HFile.WriterFactory withOutputStream(org.apache.hadoop.fs.FSDataOutputStream ostream)
public HFile.WriterFactory withBlockSize(int blockSize)
public HFile.WriterFactory withCompression(Compression.Algorithm compression)
public HFile.WriterFactory withCompression(String compressAlgo)
public HFile.WriterFactory withDataBlockEncoder(HFileDataBlockEncoder encoder)
public HFile.WriterFactory withComparator(KeyValue.KVComparator comparator)
public HFile.WriterFactory withFavoredNodes(InetSocketAddress[] favoredNodes)
public HFile.WriterFactory withChecksumType(ChecksumType checksumType)
public HFile.WriterFactory withBytesPerChecksum(int bytesPerChecksum)
public HFile.WriterFactory includeMVCCReadpoint(boolean includeMVCCReadpoint)
includeMVCCReadpoint
- whether to write the mvcc readpoint to the file for each KVpublic HFile.Writer create() throws IOException
IOException
protected abstract HFile.Writer createWriter(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path path, org.apache.hadoop.fs.FSDataOutputStream ostream, int blockSize, Compression.Algorithm compress, HFileDataBlockEncoder dataBlockEncoder, KeyValue.KVComparator comparator, ChecksumType checksumType, int bytesPerChecksum, boolean includeMVCCReadpoint) throws IOException
IOException
Copyright © 2013 The Apache Software Foundation. All rights reserved.