public class JobSchedulerKahaDBMetaData extends AbstractKahaDBMetaData<JobSchedulerKahaDBMetaData>
CLOSED_STATE, OPEN_STATE
Constructor and Description |
---|
JobSchedulerKahaDBMetaData(JobSchedulerStoreImpl store)
Creates a new instance of this meta data object with the assigned
parent JobSchedulerStore instance.
|
Modifier and Type | Method and Description |
---|---|
BTreeIndex<String,JobSchedulerImpl> |
getJobSchedulers()
Gets the index of JobScheduler instances that have been created and stored
in the JobSchedulerStore instance.
|
BTreeIndex<Integer,Integer> |
getJournalRC()
Gets the index used to track the number of reference to a Journal log file.
|
BTreeIndex<Integer,List<Integer>> |
getRemoveLocationTracker()
Gets the index that contains the location tracking information for Jobs
that have been removed from the index but whose add operation has yet
to be removed from the Journal.
|
UUID |
getToken() |
int |
getVersion() |
void |
initialize(Transaction tx)
For a newly created KahaDBMetaData instance this method is called to allow
the instance to create all of it's internal indices and other state data.
|
void |
load(Transaction tx)
Instructs this object to load its internal data structures from the KahaDB PageFile
and prepare itself for use.
|
void |
loadScheduler(Transaction tx,
Map<String,JobSchedulerImpl> schedulers)
Loads all the stored JobScheduler instances into the provided map.
|
void |
read(DataInput in)
Reads the serialized for of this object from the KadaDB PageFile and prepares it
for use.
|
void |
write(DataOutput out)
Writes the object into a serialized form which can be read back in again using the
read method.
|
getLastUpdateLocation, getPage, getState, setLastUpdateLocation, setPage, setState
public JobSchedulerKahaDBMetaData(JobSchedulerStoreImpl store)
store
- the store instance that owns this meta data.public UUID getToken()
public int getVersion()
public BTreeIndex<Integer,List<Integer>> getRemoveLocationTracker()
public BTreeIndex<Integer,Integer> getJournalRC()
public BTreeIndex<String,JobSchedulerImpl> getJobSchedulers()
public void initialize(Transaction tx) throws IOException
KahaDBMetaData
tx
- the Transaction instance under which the operation is executed.IOException
- if an error occurs while creating the meta data structures.public void load(Transaction tx) throws IOException
KahaDBMetaData
tx
- the Transaction instance under which the operation is executed.IOException
- if an error occurs while creating the meta data structures.public void loadScheduler(Transaction tx, Map<String,JobSchedulerImpl> schedulers) throws IOException
tx
- the Transaction under which the load operation should be executed.schedulers
- a MapIOException
- if an error occurs while performing the load operation.public void read(DataInput in) throws IOException
KahaDBMetaData
in
- the DataInput instance used to read this objects serialized form.IOException
- if an error occurs while reading the serialized form.public void write(DataOutput out) throws IOException
KahaDBMetaData
out
- the DataOutput instance to use to write the current state to a serialized form.IOException
- if an error occurs while serializing this instance.Copyright © 2005–2019 The Apache Software Foundation. All rights reserved.