com.neurosys.etl.process

Class ProcessState<P extends Process,B,T,F>

java.lang.Object

com.neurosys.etl.process.ProcessState<P,B,T,F>

All Implemented Interfaces:

Serializable

public class ProcessState<P extends Process,B,T,F>
extends Object
implements Serializable

A process state defines the exact state of a process where it is in terms of:

• Process that owns the state
• Current Batch/Buffer (if applicable/loaded)
• Tuple/Node (if loaded)
• Property/Field (if loaded)

Author:

Arjun Dhar

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ProcessState(P process)

Method Summary

Modifier and Type	Method and Description
B	getBatch()
Exception	getException()
P	getProcess()
F	getProperty()
Map<String,Serializable>	getPropertyAttributes()
String	getPropertyName()
T	getTuple()
void	setBatch(B batch)
void	setException(Exception exception)
void	setProcess(P process)
void	setProperty(String propertyName, F property)
void	setPropertyAttributes(Map<String,Serializable> propertyAttributes)
void	setPropertyName(String propertyName)
void	setTuple(T tuple)

Methods inherited from class java.lang.Object

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

Constructor Detail

ProcessState

public ProcessState(P process)

Method Detail

getProcess

public P getProcess()

setProcess

public void setProcess(P process)

getBatch

public B getBatch()

setBatch

public void setBatch(B batch)

getTuple

public T getTuple()

setTuple

public void setTuple(T tuple)

getProperty

public F getProperty()

setProperty

public void setProperty(String propertyName,
                        F property)

getPropertyName

public String getPropertyName()

setPropertyName

public void setPropertyName(String propertyName)

getPropertyAttributes

public Map<String,Serializable> getPropertyAttributes()

setPropertyAttributes

public void setPropertyAttributes(Map<String,Serializable> propertyAttributes)

getException

public Exception getException()

setException

public void setException(Exception exception)