com.sleepycat.je.rep.stream
Class MasterFeederSource
java.lang.Object
com.sleepycat.je.rep.stream.MasterFeederSource
- All Implemented Interfaces:
- FeederSource
public class MasterFeederSource
- extends Object
- implements FeederSource
Implementation of a master node acting as a FeederSource. The
MasterFeederSource is stateful, because it keeps its own FeederReader which
acts as a cursor or scanner across the log files, so it can only be used by
a single Feeder.
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
MasterFeederSource
public MasterFeederSource(EnvironmentImpl envImpl,
VLSNIndex vlsnIndex,
NameIdPair nameIdPair)
throws DatabaseException
- Throws:
DatabaseException
init
public void init(VLSN startVLSN)
throws DatabaseException,
IOException
- Specified by:
init
in interface FeederSource
- Throws:
DatabaseException
IOException
getWireRecord
public OutputWireRecord getWireRecord(VLSN vlsn,
int waitTime)
throws DatabaseException,
InterruptedException,
IOException
- Specified by:
getWireRecord
in interface FeederSource
- Throws:
DatabaseException
InterruptedException
IOException
dumpState
public String dumpState()
- Specified by:
dumpState
in interface FeederSource
Copyright (c) 2004-2012 Oracle. All rights reserved.