Package org.cdlib.mrt.tools.loader

Class StoreLoader

java.lang.Object

org.cdlib.mrt.utility.ListProcessorBase

org.cdlib.mrt.utility.ListProcessorSimple

org.cdlib.mrt.tools.loader.StoreLoader

All Implemented Interfaces:

ListProcessor

public class StoreLoader
extends ListProcessorSimple
implements ListProcessor

Run a Storage load test

Author:

dloy

Field Summary

Fields

Modifier and Type	Field	Description
protected String	checksumType
protected URL	componentURLBase
static boolean	DEBUG
static final int	DEFAULTDELTA
protected File	extractBaseDirectory
static final String	LS
protected String	MESSAGE
protected String	NAME
protected int	nodeID
protected File	outputBatchFile
protected URL	outputManifestBaseURL
protected File	outputManifestDirectoryBase
protected URL	outputManifestURL
protected File	processList
protected URL	storageBase
protected StorageAddClient	storeAddClient
static boolean	SUBMIT

Fields inherited from class org.cdlib.mrt.utility.ListProcessorSimple

m_clientProperties

Fields inherited from class org.cdlib.mrt.utility.ListProcessorBase

logger, m_framework, m_status, PROCESSCNT, PROCESSTIME, TOTALBYTES, TOTALTIME

Constructor Summary

Constructors

Constructor	Description
StoreLoader(TFrame framework)

Method Summary

Modifier and Type	Method	Description
Properties	addVersion(int nodeID, Identifier objectID, String localContext, String localID, File manifest, Long size, MessageDigest manifestMessageDigest)
void	end()	Process on EnrichmentList item
String	getName()	Name of EnrichmentList
protected void	initialize(TFrame fw)
protected void	initializeStoreLoader()
protected void	log(String msg)
static void	main(String[] args)	Main method
void	process(String line, Properties processProp)	Process an incoming line which contains 1) ark 2) sequence number Use the ark for issuing an addVersion to a storage service
protected LoaderManifest	processManifest(String dirName, FileComponent batchComponent, File extractDirectory, String localID, String primaryID)

Methods inherited from class org.cdlib.mrt.utility.ListProcessorSimple

getClientProperties, getIntProp, processList

Methods inherited from class org.cdlib.mrt.utility.ListProcessorBase

getFileProperties, log, requiredProp

Methods inherited from class java.lang.Object

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

Field Details

NAME

protected String NAME

MESSAGE

protected String MESSAGE

LS

public static final String LS

DEFAULTDELTA

public static final int DEFAULTDELTA

See Also:

• Constant Field Values

DEBUG

public static boolean DEBUG

SUBMIT

public static boolean SUBMIT

checksumType

protected String checksumType

processList

protected File processList

extractBaseDirectory

protected File extractBaseDirectory

outputManifestDirectoryBase

protected File outputManifestDirectoryBase

outputManifestBaseURL

protected URL outputManifestBaseURL

componentURLBase

protected URL componentURLBase

outputManifestURL

protected URL outputManifestURL

outputBatchFile

protected File outputBatchFile

storageBase

protected URL storageBase

nodeID

protected int nodeID

storeAddClient

protected StorageAddClient storeAddClient

Constructor Details

StoreLoader

public StoreLoader(TFrame framework)
            throws TException

Throws:

TException

Method Details

main

public static void main(String[] args)

Main method

initialize

protected void initialize(TFrame fw)
                   throws TException

Overrides:

initialize in class ListProcessorSimple

Throws:

TException

initializeStoreLoader

protected void initializeStoreLoader()
                              throws TException

Throws:

TException

getName

public String getName()

Name of EnrichmentList

Specified by:

getName in interface ListProcessor

Overrides:

getName in class ListProcessorSimple

Returns:

name to be applied for identifying process properties

process

public void process(String line,
 Properties processProp)
             throws TException

 Process an incoming line which contains
 1) ark
 2) sequence number
 Use the ark for issuing an addVersion to a storage service
 

Specified by:

process in interface ListProcessor

Overrides:

process in class ListProcessorSimple

Parameters:

line - line containing ark and sequence number

processProp - runtime properties

Throws:

TException - process exception

processManifest

protected LoaderManifest processManifest(String dirName,
 FileComponent batchComponent,
 File extractDirectory,
 String localID,
 String primaryID)
                                  throws TException

Throws:

TException

log

protected void log(String msg)

addVersion

public Properties addVersion(int nodeID,
 Identifier objectID,
 String localContext,
 String localID,
 File manifest,
 Long size,
 MessageDigest manifestMessageDigest)
                      throws TException

Throws:

TException

end

public void end()
         throws TException

Description copied from class: ListProcessorSimple

Process on EnrichmentList item

Overrides:

end in class ListProcessorSimple

Throws:

TException