ds.granules.interfere.streaming

Class GIStreamingNode

java.lang.Object

ds.funnel.node.compnt.NodeComponentImpl

ds.funnel.node.NodeBase

ds.granules.interfere.streaming.GIStreamingNode

All Implemented Interfaces:

ComponentManager, NodeComponent, Node, GIStreamingProxyOps

public class GIStreamingNode
extends NodeBase
implements GIStreamingProxyOps

Nested Class Summary

Nested classes/interfaces inherited from interface ds.funnel.node.Node

Node.NodeState

Field Summary

Fields

Modifier and Type	Field and Description
static java.io.PrintWriter	eventLogFile
static java.lang.String	eventLogPath
static boolean	recordActive
static java.util.Map<java.lang.String,java.lang.String>	resourceNames

Constructor Summary

Constructors

Constructor and Description
GIStreamingNode(java.lang.String... args)

Method Summary

Modifier and Type	Method and Description
GIStreamingDetails	getDetails()
static GIStreamingNode	getNode()
static void	main(java.lang.String[] args)
void	setFileLogging(boolean inActive, java.util.Map<java.lang.String,java.lang.String> inResourceNames)
void	shutdown()
java.util.UUID	startStream(ComputationDescription inCompDesc)
boolean	stopStream(java.util.UUID inHandle)

Methods inherited from class ds.funnel.node.NodeBase

enterMultiCommands, getComponent, getName, getState, registerComponent, runCommand, runTask, startNode, stopNode, toString, unregisterComponent

Methods inherited from class ds.funnel.node.compnt.NodeComponentImpl

getComponentKey, getComponentLink, hashCode, setComponentKey, startComponent, stopComponent

Methods inherited from class java.lang.Object

equals, getClass, notify, notifyAll, wait, wait, wait

Field Detail

recordActive

public static volatile boolean recordActive

resourceNames

public static volatile java.util.Map<java.lang.String,java.lang.String> resourceNames

eventLogPath

public static java.lang.String eventLogPath

eventLogFile

public static java.io.PrintWriter eventLogFile

Constructor Detail

GIStreamingNode

public GIStreamingNode(java.lang.String... args)

Method Detail

getNode

public static GIStreamingNode getNode()

main

public static void main(java.lang.String[] args)
                 throws java.lang.Exception

Throws:

java.lang.Exception

getDetails

public GIStreamingDetails getDetails()

Specified by:

getDetails in interface Node

Overrides:

getDetails in class NodeBase

Returns:

The address and other details of this node.

startStream

public java.util.UUID startStream(ComputationDescription inCompDesc)
                           throws ComponentException

Specified by:

startStream in interface GIStreamingProxyOps

Throws:

ComponentException

stopStream

public boolean stopStream(java.util.UUID inHandle)

Specified by:

stopStream in interface GIStreamingProxyOps

setFileLogging

public void setFileLogging(boolean inActive,
                           java.util.Map<java.lang.String,java.lang.String> inResourceNames)

Specified by:

setFileLogging in interface GIStreamingProxyOps

shutdown

public void shutdown()

Specified by:

shutdown in interface GIStreamingProxyOps