Package org.apache.accumulo.core.file.rfile

Class RFile.Writer

java.lang.Object

org.apache.accumulo.core.file.rfile.RFile.Writer

All Implemented Interfaces:

AutoCloseable, FileSKVWriter

Enclosing class:

RFile

public static class RFile.Writer
extends Object
implements FileSKVWriter

Field Summary

Fields

Modifier and Type	Field	Description
static int	MAX_CF_IN_DLG

Constructor Summary

Constructors

Constructor	Description
Writer(BCFile.Writer bfw, int blockSize)
Writer(BCFile.Writer bfw, int blockSize, int indexBlockSize, SamplerConfigurationImpl samplerConfig, Sampler sampler)

Method Summary

Modifier and Type	Method	Description
void	append(Key key, Value value)
void	close()
DataOutputStream	createMetaStore(String name)
long	getLength()
void	startDefaultLocalityGroup()
void	startNewLocalityGroup(String name, Set<ByteSequence> columnFamilies)
boolean	supportsLocalityGroups()

Methods inherited from class java.lang.Object

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

Field Detail

MAX_CF_IN_DLG

public static final int MAX_CF_IN_DLG

See Also:

Constant Field Values

Constructor Detail

Writer

public Writer(BCFile.Writer bfw,
              int blockSize)
       throws IOException

Throws:

IOException

Writer

public Writer(BCFile.Writer bfw,
              int blockSize,
              int indexBlockSize,
              SamplerConfigurationImpl samplerConfig,
              Sampler sampler)

Method Detail

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface FileSKVWriter

Throws:

IOException

append

public void append(Key key,
                   Value value)
            throws IOException

Specified by:

append in interface FileSKVWriter

Throws:

IOException

createMetaStore

public DataOutputStream createMetaStore(String name)
                                 throws IOException

Specified by:

createMetaStore in interface FileSKVWriter

Throws:

IOException

startNewLocalityGroup

public void startNewLocalityGroup(String name,
                                  Set<ByteSequence> columnFamilies)
                           throws IOException

Specified by:

startNewLocalityGroup in interface FileSKVWriter

Throws:

IOException

startDefaultLocalityGroup

public void startDefaultLocalityGroup()
                               throws IOException

Specified by:

startDefaultLocalityGroup in interface FileSKVWriter

Throws:

IOException

supportsLocalityGroups

public boolean supportsLocalityGroups()

Specified by:

supportsLocalityGroups in interface FileSKVWriter

getLength

public long getLength()

Specified by:

getLength in interface FileSKVWriter