com.persistit

Class StreamLoader.ImportHandler

java.lang.Object

com.persistit.StreamLoader.ImportHandler

Enclosing class:

StreamLoader

protected static class StreamLoader.ImportHandler
extends Object

Handler for various record types in stream being loaded.

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	_createMissingTrees
protected boolean	_createMissingVolumes
protected Exchange	_exchange
protected KeyFilter	_keyFilter
protected Persistit	_persistit
protected Tree	_tree
protected String	_treeName
protected TreeSelector	_treeSelector
protected Volume	_volume
protected String	_volumeName

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ImportHandler(Persistit persistit)
protected	ImportHandler(Persistit persistit, TreeSelector treeSelector, boolean createMissingVolumes, boolean createMissingTrees)

Method Summary

Modifier and Type	Method and Description
protected void	handleCommentRecord(String comment)
protected void	handleCompletionRecord()
protected void	handleCountRecord(long keyValueRecords, long otherRecords)
protected void	handleDataRecord(Key key, Value value)
protected void	handleEndRecord()
protected void	handleExceptionRecord(String exceptionString)
protected void	handleFillRecord()
protected void	handleHostNameRecord(String hostName)
protected void	handleKeyFilterRecord(String keyFilterString)
protected void	handleStartRecord()
protected void	handleTimeStampRecord(long timeStamp)
protected void	handleTreeIdRecord(String treeName)
protected void	handleUserRecord(String userName)
protected void	handleVolumeIdRecord(long volumeId, long initialPages, long extensionPages, long maximumPages, int bufferSize, String path, String name)

Methods inherited from class java.lang.Object

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

Field Detail

_persistit

protected Persistit _persistit

_treeSelector

protected TreeSelector _treeSelector

_exchange

protected Exchange _exchange

_volume

protected Volume _volume

_tree

protected Tree _tree

_keyFilter

protected KeyFilter _keyFilter

_createMissingVolumes

protected boolean _createMissingVolumes

_createMissingTrees

protected boolean _createMissingTrees

_volumeName

protected String _volumeName

_treeName

protected String _treeName

Constructor Detail

ImportHandler

protected ImportHandler(Persistit persistit)

ImportHandler

protected ImportHandler(Persistit persistit,
                        TreeSelector treeSelector,
                        boolean createMissingVolumes,
                        boolean createMissingTrees)

Method Detail

handleFillRecord

protected void handleFillRecord()
                         throws PersistitException

Throws:

PersistitException

handleDataRecord

protected void handleDataRecord(Key key,
                                Value value)
                         throws PersistitException

Throws:

PersistitException

handleKeyFilterRecord

protected void handleKeyFilterRecord(String keyFilterString)
                              throws PersistitException

Throws:

PersistitException

handleVolumeIdRecord

protected void handleVolumeIdRecord(long volumeId,
                                    long initialPages,
                                    long extensionPages,
                                    long maximumPages,
                                    int bufferSize,
                                    String path,
                                    String name)
                             throws PersistitException

Throws:

PersistitException

handleTreeIdRecord

protected void handleTreeIdRecord(String treeName)
                           throws PersistitException

Throws:

PersistitException

handleTimeStampRecord

protected void handleTimeStampRecord(long timeStamp)
                              throws PersistitException

Throws:

PersistitException

handleHostNameRecord

protected void handleHostNameRecord(String hostName)
                             throws PersistitException

Throws:

PersistitException

handleUserRecord

protected void handleUserRecord(String userName)
                         throws PersistitException

Throws:

PersistitException

handleCommentRecord

protected void handleCommentRecord(String comment)
                            throws PersistitException

Throws:

PersistitException

handleCountRecord

protected void handleCountRecord(long keyValueRecords,
                                 long otherRecords)
                          throws PersistitException

Throws:

PersistitException

handleStartRecord

protected void handleStartRecord()
                          throws PersistitException

Throws:

PersistitException

handleEndRecord

protected void handleEndRecord()
                        throws PersistitException

Throws:

PersistitException

handleExceptionRecord

protected void handleExceptionRecord(String exceptionString)
                              throws PersistitException

Throws:

PersistitException

handleCompletionRecord

protected void handleCompletionRecord()
                               throws PersistitException

Throws:

PersistitException