com.persistit

Class StreamLoader

java.lang.Object

com.persistit.Task

com.persistit.StreamLoader

All Implemented Interfaces:

Runnable

public class StreamLoader
extends Task

Loads Persistit records from a file or other stream in a format generated by a StreamSaver.

Version:

1.0

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	StreamLoader.ImportHandler 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 int	_dataRecordCount
protected DataInputStream	_dis
protected String	_filePath
protected StreamLoader.ImportHandler	_handler
protected Key	_key
protected Exception	_lastException
protected Tree	_lastTree
protected Volume	_lastVolume
protected int	_otherRecordCount
protected boolean	_stop
protected TreeSelector	_treeSelector
protected Value	_value
static int	DEFAULT_BUFFER_SIZE Default for BufferedInputStream buffer size.

Fields inherited from class com.persistit.Task

_culledMessageCount, _description, _expirationTime, _finishTime, _maxMessageLogSize, _messageLog, _messageLogVerbosity, _messageWriter, _owner, _persistit, _startTime, _state, _suspend, _suspendedDuration, _taskId, _thread, DEFAULT_MAX_MESSAGE_LOG_SIZE, LOG_NORMAL, LOG_VERBOSE, STATE_DONE, STATE_ENDED, STATE_EXPIRED, STATE_FAILED, STATE_NAMES, STATE_NOT_STARTED, STATE_RUNNING, STATE_SUSPENDED

Constructor Summary

Constructors

Constructor and Description
StreamLoader(Persistit persistit, DataInputStream dis)
StreamLoader(Persistit persistit, File file)
StreamLoader(Persistit persistit, String fileName)

Method Summary

Modifier and Type	Method and Description
void	close()
String	getStatus() Returns a short String message describing the current state of this Task.
void	load()
void	load(StreamLoader.ImportHandler handler)
void	load(TreeSelector treeSelector, boolean createMissingVolumes, boolean createMissingTrees)
boolean	next(StreamLoader.ImportHandler handler)
void	runTask() Called by a newly created Thread to perform the task.

Methods inherited from class com.persistit.Task

appendMessage, cullMessages, endMessage, getMessageLogSize, getMessageLogVerbosity, getMessages, getMessageWriter, getRemainingTime, getStatusDetail, isImmediate, now, parseTreeList, poll, populateTaskStatus, postMessage, resume, run, setMaximumTime, setMessageLogVerbosity, setMessageWriter, setPersistit, setup, start, stop, suspend

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_BUFFER_SIZE

public static final int DEFAULT_BUFFER_SIZE

Default for BufferedInputStream buffer size.

See Also:

Constant Field Values

_filePath

protected String _filePath

_dis

protected DataInputStream _dis

_key

protected Key _key

_value

protected Value _value

_lastVolume

protected Volume _lastVolume

_lastTree

protected Tree _lastTree

_dataRecordCount

protected int _dataRecordCount

_otherRecordCount

protected int _otherRecordCount

_stop

protected boolean _stop

_lastException

protected Exception _lastException

_treeSelector

protected TreeSelector _treeSelector

_createMissingVolumes

protected boolean _createMissingVolumes

_createMissingTrees

protected boolean _createMissingTrees

_handler

protected StreamLoader.ImportHandler _handler

Constructor Detail

StreamLoader

public StreamLoader(Persistit persistit,
                    DataInputStream dis)

StreamLoader

public StreamLoader(Persistit persistit,
                    File file)
             throws IOException

Throws:

IOException

StreamLoader

public StreamLoader(Persistit persistit,
                    String fileName)
             throws IOException

Throws:

IOException

Method Detail

close

public void close()
           throws IOException

Throws:

IOException

load

public void load()
          throws IOException,
                 PersistitException

Throws:

IOException

PersistitException

load

public void load(TreeSelector treeSelector,
                 boolean createMissingVolumes,
                 boolean createMissingTrees)
          throws IOException,
                 PersistitException

Throws:

IOException

PersistitException

load

public void load(StreamLoader.ImportHandler handler)
          throws IOException,
                 PersistitException

Throws:

IOException

PersistitException

next

public boolean next(StreamLoader.ImportHandler handler)
             throws IOException,
                    PersistitException

Throws:

IOException

PersistitException

runTask

public void runTask()
             throws Exception

Description copied from class: Task

Called by a newly created Thread to perform the task.

Specified by:

runTask in class Task

Throws:

Exception

getStatus

public String getStatus()

Description copied from class: Task

Returns a short String message describing the current state of this Task. It should convey a measurement of progress to the end-user.

Specified by:

getStatus in class Task

Returns:

A description of this Task's current state