com.bigdata.rdf.load
Class MappedRDFDataLoadMaster.JobState

java.lang.Object
  com.bigdata.service.jini.master.TaskMaster.JobState
      com.bigdata.service.jini.master.MappedTaskMaster.JobState
          com.bigdata.rdf.load.MappedRDFDataLoadMaster.JobState

All Implemented Interfaces:

Serializable

Enclosing class:

MappedRDFDataLoadMaster<S extends MappedRDFDataLoadMaster.JobState,T extends AbstractAsynchronousClientTask<U,V,L>,U,L extends ClientLocator,V extends Serializable>

public static class MappedRDFDataLoadMaster.JobState
extends MappedTaskMaster.JobState

The job description for an MappedRDFDataLoadMaster.

Version:

$Id: MappedRDFDataLoadMaster.java 6045 2012-02-27 17:33:44Z thompsonbry $

Author:

Bryan Thompson

See Also:

Serialized Form

Field Summary

int	bnodesInitialCapacity
boolean	computeClosure When true, the closure of the data set will be computed once all data have been loaded.
boolean	create When true, the master will create the ITripleStore identified by namespace if it does not exist.
String	defaultGraph The value that will be used for the graph/context co-ordinate when loading data represented in a triple format into a quad store.
boolean	loadData When true, the clients will load data.
String	namespace The namespace of the ITripleStore into which the data will be loaded (must exist).
int	notifyPoolSize
File	ontology The file or directory from which files will be loaded when the ITripleStore is first created.
FilenameFilter	ontologyFileFilter Only files matched by the filter will be processed (optional, but must be Serializable).
int	otherWriterPoolSize
RDFParserOptions	parserOptions The options for the RDFParser instances.
int	parserPoolSize
int	parserQueueCapacity
int	producerChunkSize
long	rejectedExecutionDelay
int	term2IdWriterPoolSize
long	unbufferedStatementThreshold
int	valuesInitialCapacity

Fields inherited from class com.bigdata.service.jini.master.MappedTaskMaster.JobState

clientHashFunction, conf, deleteAfter, pendingSetMasterInitialCapacity, pendingSetSubtaskInitialCapacity, scannerFactory

Fields inherited from class com.bigdata.service.jini.master.TaskMaster.JobState

aggregatorServiceMap, aggregatorsTemplate, clientServiceMap, clientsTemplate, component, forceOverflow, futures, indexDumpDir, indexDumpNamespace, jobName, naggregators, nclients, servicesDiscoveryTimeout, servicesTemplates

Constructor Summary

MappedRDFDataLoadMaster.JobState(String component, net.jini.config.Configuration config)

Method Summary

RDFFormat	getRDFFormat() The RDFFormat that will be used when the format can not be deduced from the file extension or other metadata.
protected void	toString(StringBuilder sb) Allows extension of TaskMaster.JobState.toString()

Methods inherited from class com.bigdata.service.jini.master.TaskMaster.JobState

getClientZPath, getElapsedMillis, getJobClassZPath, getJobZPath, getLockNodeZPath, isResumedJob, toString

Methods inherited from class java.lang.Object

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

Field Detail

namespace

public final String namespace

The namespace of the ITripleStore into which the data will be loaded (must exist).

ontology

public final File ontology

The file or directory from which files will be loaded when the ITripleStore is first created.

See Also:

MappedRDFDataLoadMaster.ConfigurationOptions.ONTOLOGY

ontologyFileFilter

public final FilenameFilter ontologyFileFilter

Only files matched by the filter will be processed (optional, but must be Serializable).

See Also:

MappedRDFDataLoadMaster.ConfigurationOptions.ONTOLOGY_FILE_FILTER

parserPoolSize

public final int parserPoolSize

See Also:

MappedRDFDataLoadMaster.ConfigurationOptions.PARSER_POOL_SIZE

parserQueueCapacity

public final int parserQueueCapacity

See Also:

MappedRDFDataLoadMaster.ConfigurationOptions.PARSER_QUEUE_CAPACITY

rejectedExecutionDelay

public final long rejectedExecutionDelay

See Also:

MappedRDFDataLoadMaster.ConfigurationOptions.REJECTED_EXECUTION_DELAY

term2IdWriterPoolSize

public final int term2IdWriterPoolSize

See Also:

MappedRDFDataLoadMaster.ConfigurationOptions.TERM2ID_WRITER_POOL_SIZE

otherWriterPoolSize

public final int otherWriterPoolSize

See Also:

MappedRDFDataLoadMaster.ConfigurationOptions.OTHER_WRITER_POOL_SIZE

notifyPoolSize

public final int notifyPoolSize

See Also:

MappedRDFDataLoadMaster.ConfigurationOptions.NOTIFY_POOL_SIZE

unbufferedStatementThreshold

public final long unbufferedStatementThreshold

See Also:

MappedRDFDataLoadMaster.ConfigurationOptions.UNBUFFERED_STATEMENT_THRESHOLD

producerChunkSize

public final int producerChunkSize

See Also:

MappedRDFDataLoadMaster.ConfigurationOptions.PRODUCER_CHUNK_SIZE

valuesInitialCapacity

public final int valuesInitialCapacity

See Also:

MappedRDFDataLoadMaster.ConfigurationOptions.VALUES_INITIAL_CAPACITY

bnodesInitialCapacity

public final int bnodesInitialCapacity

See Also:

MappedRDFDataLoadMaster.ConfigurationOptions.BNODES_INITIAL_CAPACITY

create

public final boolean create

When true, the master will create the ITripleStore identified by namespace if it does not exist.

loadData

public final boolean loadData

When true, the clients will load data.

computeClosure

public final boolean computeClosure

When true, the closure of the data set will be computed once all data have been loaded.

parserOptions

public final RDFParserOptions parserOptions

The options for the RDFParser instances.

See Also:

MappedRDFDataLoadMaster.ConfigurationOptions.PARSER_OPTIONS

defaultGraph

public final String defaultGraph

The value that will be used for the graph/context co-ordinate when loading data represented in a triple format into a quad store.

Constructor Detail

MappedRDFDataLoadMaster.JobState

public MappedRDFDataLoadMaster.JobState(String component,
                                        net.jini.config.Configuration config)
                                 throws net.jini.config.ConfigurationException

Throws:

net.jini.config.ConfigurationException

Method Detail

getRDFFormat

public RDFFormat getRDFFormat()

The RDFFormat that will be used when the format can not be deduced from the file extension or other metadata.

toString

protected void toString(StringBuilder sb)

Description copied from class: TaskMaster.JobState

Allows extension of TaskMaster.JobState.toString()

Overrides:

toString in class MappedTaskMaster.JobState