Package org.jppf.job.persistence

Class PersistenceInfoImpl

java.lang.Object

org.jppf.job.persistence.PersistenceInfoImpl

All Implemented Interfaces:

Serializable, PersistenceInfo

public class PersistenceInfoImpl
extends Object
implements PersistenceInfo

Implementation of the PersistenceInfo interface.

Author:

Laurent Cohen

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
PersistenceInfoImpl(String jobUuid, JPPFDistributedJob job, PersistenceObjectType type, int taskPosition, DataLocation dataLocation)	Initialize this persistence information object.

Method Summary

Modifier and Type	Method	Description
InputStream	getInputStream()	Get an input stream for the persisted object.
JPPFDistributedJob	getJob()	Get the related job information.
String	getJobUuid()	Get the job uuid.
int	getPosition()	Get the position of the task in the job.
int	getSize()	Get the size in bytes of the persisted object.
PersistenceObjectType	getType()	Get the type of persisted object.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Details

PersistenceInfoImpl

public PersistenceInfoImpl(String jobUuid,
 JPPFDistributedJob job,
 PersistenceObjectType type,
 int taskPosition,
 DataLocation dataLocation)

Initialize this persistence information object.

Parameters:

jobUuid - the job uuid.

job - the job information, if applicable.

type - the type of persisted object.

taskPosition - the position of the task in the job, if applicable.

dataLocation - the location of the persisted object's data.

Method Details

getJobUuid

public String getJobUuid()

Description copied from interface: PersistenceInfo

Get the job uuid.

Specified by:

getJobUuid in interface PersistenceInfo

Returns:

the uuid of the related job as a string.

getJob

public JPPFDistributedJob getJob()

Description copied from interface: PersistenceInfo

Get the related job information.

Specified by:

getJob in interface PersistenceInfo

Returns:

a JPPFDistributedJob instance, or null if the job is not loaded.

getType

public PersistenceObjectType getType()

Description copied from interface: PersistenceInfo

Get the type of persisted object.

Specified by:

getType in interface PersistenceInfo

Returns:

one of the possible values of the PersistenceObjectType enum.

getPosition

public int getPosition()

Description copied from interface: PersistenceInfo

Get the position of the task in the job.

Specified by:

getPosition in interface PersistenceInfo

Returns:

the position of the task in the job, starting at 0, or -1 if the persisted object is neither a task nor a task result.

getInputStream

public InputStream getInputStream()
                           throws Exception

Description copied from interface: PersistenceInfo

Get an input stream for the persisted object.

Specified by:

getInputStream in interface PersistenceInfo

Returns:

an InputStream instance, or null if the object has not yet been loaded.

Throws:

Exception - if any error occurs.

toString

public String toString()

Overrides:

toString in class Object

getSize

public int getSize()

Description copied from interface: PersistenceInfo

Get the size in bytes of the persisted object.

Specified by:

getSize in interface PersistenceInfo

Returns:

the size of the persisted data, or -1 if the size is not known.