Package org.apache.accumulo.core.summary

Class SummaryWriter

java.lang.Object

org.apache.accumulo.core.summary.SummaryWriter

All Implemented Interfaces:

AutoCloseable, FileSKVWriter

public class SummaryWriter
extends Object
implements FileSKVWriter

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()
static FileSKVWriter	wrap(FileSKVWriter writer, AccumuloConfiguration tableConfig, boolean useAccumuloStart)
void	writeConfig(SummarizerConfiguration conf, DataOutputStream dos)

Methods inherited from class java.lang.Object

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

Method Detail

supportsLocalityGroups

public boolean supportsLocalityGroups()

Specified by:

supportsLocalityGroups in interface FileSKVWriter

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

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

writeConfig

public void writeConfig(SummarizerConfiguration conf,
                        DataOutputStream dos)
                 throws IOException

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface FileSKVWriter

Throws:

IOException

getLength

public long getLength()
               throws IOException

Specified by:

getLength in interface FileSKVWriter

Throws:

IOException

wrap

public static FileSKVWriter wrap(FileSKVWriter writer,
                                 AccumuloConfiguration tableConfig,
                                 boolean useAccumuloStart)