com.bigdata.service.jini.master
Class MappedTaskMaster.JobState

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

All Implemented Interfaces:

Serializable

Direct Known Subclasses:

MappedRDFDataLoadMaster.JobState

Enclosing class:

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

public static class MappedTaskMaster.JobState
extends TaskMaster.JobState

The job description for an MappedTaskMaster.

Version:

$Id$

Author:

Bryan Thompson

See Also:

Serialized Form

Field Summary

IHashFunction	clientHashFunction
protected AsynchronousIndexWriteConfiguration	conf Configuration for the buffer used to pass resources to the client tasks.
boolean	deleteAfter When true, the each data file will be deleted once its data has been loaded into the ITripleStore.
int	pendingSetMasterInitialCapacity
int	pendingSetSubtaskInitialCapacity
protected IResourceScannerFactory<?>	scannerFactory Factory for the scanner selecting the resources to be processed.

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

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

Method Summary

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

conf

protected final AsynchronousIndexWriteConfiguration conf

Configuration for the buffer used to pass resources to the client tasks.

See Also:

MappedTaskMaster.ConfigurationOptions.RESOURCE_BUFFER_CONFIG

scannerFactory

protected final IResourceScannerFactory<?> scannerFactory

Factory for the scanner selecting the resources to be processed.

See Also:

MappedTaskMaster.ConfigurationOptions.RESOURCE_SCANNER_FACTORY

pendingSetMasterInitialCapacity

public final int pendingSetMasterInitialCapacity

See Also:

MappedTaskMaster.ConfigurationOptions.PENDING_SET_MASTER_INITIAL_CAPACITY

pendingSetSubtaskInitialCapacity

public final int pendingSetSubtaskInitialCapacity

See Also:

MappedTaskMaster.ConfigurationOptions.PENDING_SET_SUBTASK_INITIAL_CAPACITY

clientHashFunction

public final IHashFunction clientHashFunction

See Also:

MappedTaskMaster.ConfigurationOptions.CLIENT_HASH_FUNCTION

deleteAfter

public final boolean deleteAfter

When true, the each data file will be deleted once its data has been loaded into the ITripleStore.

See Also:

Constructor Detail

MappedTaskMaster.JobState

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

Throws:

net.jini.config.ConfigurationException

Method Detail

toString

protected void toString(StringBuilder sb)

Description copied from class: TaskMaster.JobState

Allows extension of TaskMaster.JobState.toString()

Overrides:

toString in class TaskMaster.JobState