edu.iu.dsc.tws.api.compute.nodes

Class BaseNode

java.lang.Object

edu.iu.dsc.tws.api.compute.nodes.BaseNode

All Implemented Interfaces:

Closable, INode, java.io.Serializable

Direct Known Subclasses:

BaseCompute, BaseSource, BaseWindowCompute, BaseWindowSink, BaseWindowSource

public abstract class BaseNode
extends java.lang.Object
implements INode, Closable

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected Config	config
protected TaskContext	context

Constructor Summary

Constructors

Constructor and Description
BaseNode()

Method Summary

Modifier and Type	Method and Description
void	close() Close method for cleaning up the resources
void	prepare(Config cfg, TaskContext ctx) Prepare the task to be executed
void	reset() Reset the task

Methods inherited from class java.lang.Object

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

Field Detail

context

protected TaskContext context

config

protected Config config

Constructor Detail

BaseNode

public BaseNode()

Method Detail

prepare

public void prepare(Config cfg,
                    TaskContext ctx)

Description copied from interface: INode

Prepare the task to be executed

Specified by:

prepare in interface INode

Parameters:

cfg - the configuration

ctx - the task context, this has runtime information about the task

close

public void close()

Description copied from interface: Closable

Close method for cleaning up the resources

Specified by:

close in interface Closable

reset

public void reset()

Description copied from interface: Closable

Reset the task

Specified by:

reset in interface Closable