com.levigo.jadice.server.nodes

Class URLOutputNode

java.lang.Object

com.levigo.jadice.server.internal.NodeInternal

com.levigo.jadice.server.Node

com.levigo.jadice.server.nodes.URLOutputNode

All Implemented Interfaces:

Serializable

public class URLOutputNode
extends Node

This Node writes out incoming streams the specified URL.

As several incoming streams cause several resulting files, the filenames can be patternized:

• If it contains SEQUENCE_NUMBER this will be replaced by a sequential number per stream (i.e. 0..n ).
• If it contains STREAMDESCRIPTOR_FILENAME this will be replaced by the filename that the StreamDescriptor provides for particular stream.
  See: StreamDescriptor.getFileName()

Currently, the only supported protocols are:

file

stores the results on the server side

ftp

uploads the result on an FTP server

As this node is a data sink it must not have a successor.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class com.levigo.jadice.server.Node

Node.Cardinality

Field Summary

Fields

Modifier and Type	Field and Description
static String	SEQUENCE_NUMBER Pattern that will be replaced by a sequence number.
static String	STREAMDESCRIPTOR_FILENAME Pattern that will be replaced by the filename given in the StreamDescriptor.
static String[]	SUPPORTED_PROTOCOLS Protocols supported by this node.

Fields inherited from class com.levigo.jadice.server.internal.NodeInternal

limits, subsidiaryNodes

Constructor Summary

Constructors

Constructor and Description
URLOutputNode()

Method Summary

Methods

Modifier and Type	Method and Description
URL	generateEffectiveURL(StreamDescriptor sd, String seqNumber) Creates an URL for a Stream to write as specified in this node and replaces all patterns.
String	getFileNamePattern()
Node.Cardinality	getOutputCardinality() Return the output cardinality of this node, i.e. how many bundles (not streams!)
URL	getUrlPath()
String	getWorkerClassName() Return the node's associated NodeWorker full qualified class's name.
boolean	isAllowOverwrite()
void	setAllowOverwrite(boolean allowOverwrite) Flag if it's allowed to overwrite already existing files (default: false).
void	setFileNamePattern(String fileNamePattern) Set a pattern for the filename.
void	setUrlPath(URL url) Set the path of the URL (without the filename)
void	validate() Tests if all parameters are valid.
protected void	validateConfiguration()

Methods inherited from class com.levigo.jadice.server.Node

addTransportReceiver, appendSuccessor, apply, equals, getInputCardinality, getJob, getPredecessors, getSubsidiaryNodes, getSuccessors, getTransportSender, getUUID, hashCode, initialize, prependPredecessor, remove

Methods inherited from class com.levigo.jadice.server.internal.NodeInternal

addSubsidiaryNodes, getJobInternal, getLimit, getLimits, getNodeLimits, setNodeLimits

Methods inherited from class java.lang.Object

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

Field Detail

SEQUENCE_NUMBER

public static final String SEQUENCE_NUMBER

Pattern that will be replaced by a sequence number.

See Also:

Constant Field Values

STREAMDESCRIPTOR_FILENAME

public static final String STREAMDESCRIPTOR_FILENAME

Pattern that will be replaced by the filename given in the StreamDescriptor.

See Also:

StreamDescriptor.getFileName(), Constant Field Values

SUPPORTED_PROTOCOLS

public static final String[] SUPPORTED_PROTOCOLS

Protocols supported by this node.

Constructor Detail

URLOutputNode

public URLOutputNode()

Method Detail

generateEffectiveURL

public URL generateEffectiveURL(StreamDescriptor sd,
                       String seqNumber)
                         throws MalformedURLException

Creates an URL for a Stream to write as specified in this node and replaces all patterns.

Parameters:

sd - The StreamDescriptor

seqNumber - The sequence number of the Stream

Returns:

The URI where so store the Stream

Throws:

MalformedURLException - If the given parameters are not valid

validate

public void validate()
              throws IllegalArgumentException

Tests if all parameters are valid.

Throws:

IllegalArgumentException - if any of the parameters is not valid.

getWorkerClassName

public String getWorkerClassName()

Description copied from class: Node

Return the node's associated NodeWorker full qualified class's name. By default, the worker class name is

• The same as the node name with the trailing "Node" replaced by "Worker" if the node name ends in "Node"
• The node class name with an appended "Worker" otherwise.

The package name of the worker class is the name of the Node's package with an appended ".worker".

This behavior can be overridden in concrete subclasses.

Overrides:

getWorkerClassName in class Node

Returns:

the full qualified class name of the worker of this node.

getFileNamePattern

public String getFileNamePattern()

setFileNamePattern

public void setFileNamePattern(String fileNamePattern)
                        throws MalformedURLException,
                               URISyntaxException

Set a pattern for the filename.

Legal place holders are SEQUENCE_NUMBER and STREAMDESCRIPTOR_FILENAME.

Parameters:

fileNamePattern - The pattern to set

Throws:

URISyntaxException

MalformedURLException

isAllowOverwrite

public boolean isAllowOverwrite()

setAllowOverwrite

public void setAllowOverwrite(boolean allowOverwrite)

Flag if it's allowed to overwrite already existing files (default: false). In such a case an error with MessageID JS.SERVER.NODES-OVERWRITE_FORBIDDEN will be raised.

Implementation node: This flag is only respected when using the protocol file.

Parameters:

allowOverwrite - files are allowed be be overwritten iff set to true

getUrlPath

public URL getUrlPath()

setUrlPath

public void setUrlPath(URL url)
                throws MalformedURLException,
                       URISyntaxException

Set the path of the URL (without the filename)

Parameters:

url - the base URL.

Throws:

MalformedURLException

URISyntaxException

getOutputCardinality

public Node.Cardinality getOutputCardinality()

Description copied from class: Node

Return the output cardinality of this node, i.e. how many bundles (not streams!) it expects to produce. By default, nodes are "pipe-style", i.e. one input, one output.

Overrides:

getOutputCardinality in class Node

Returns:

output cardinality

validateConfiguration

protected void validateConfiguration()
                              throws ConfigurationException

Overrides:

validateConfiguration in class Node

Throws:

ConfigurationException