uk.org.ogsadai.activity.transform
Class ByteArraysToTupleActivity

java.lang.Object
  uk.org.ogsadai.activity.ActivityBase
      uk.org.ogsadai.activity.MatchedIterativeActivity
          uk.org.ogsadai.activity.transform.ByteArraysToTupleActivity

All Implemented Interfaces:

Activity

public class ByteArraysToTupleActivity
extends MatchedIterativeActivity

An activity that converts a binary tuple stream into OGSA-DAI tuples. The result is output as an OGSA-DAI list of tuples.

Activity inputs:

• data. Type: OGSA-DAI list of byte[]. This is a list of tuples rendered in an OGSA-DAI internal binary format to be converted into tuples.

Activity outputs:

• result Type: OGSA-DAI list of Tuple with the first item in the list an instance of MetadataWrapper containing a TupleMetadata object.

Configuration parameters: none.

Activity input/output ordering: none.

Activity contracts: none.

Target data resource: none.

Behaviour:

• The activity receives as input a list of tuples in binary format and converts the binary data into a list of OGSA-DAI tuples.

Author:

The OGSA-DAI Project Team.

Field Summary

Fields inherited from class uk.org.ogsadai.activity.ActivityBase

mContracts

Constructor Summary

ByteArraysToTupleActivity()

Method Summary

protected ActivityInput[]	getIterationInputs() Gets the iteration inputs.
protected void	postprocess() Performs any post-processing required after the iterative part of the activity processing has completed.
protected void	preprocess() Performs any pre-processing required before the iterative part of the activity processing commences.
protected void	processIteration(java.lang.Object[] iterationData) Performs an iteration of the activity processing.

Methods inherited from class uk.org.ogsadai.activity.MatchedIterativeActivity

cleanUp, iterativeStageComplete, process

Methods inherited from class uk.org.ogsadai.activity.ActivityBase

addInput, addOutput, close, closeDueToError, getActivityContracts, getActivityDescriptor, getInput, getInput, getInputs, getOutput, getOutput, getOutputs, hasInput, hasOutput, removeInput, setActivityDescriptor, toString, validateInput, validateInputs, validateOutput, validateOutputs

Methods inherited from class java.lang.Object

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

Constructor Detail

ByteArraysToTupleActivity

public ByteArraysToTupleActivity()

Method Detail

getIterationInputs

protected ActivityInput[] getIterationInputs()

Gets the iteration inputs.

Specified by:

getIterationInputs in class MatchedIterativeActivity

Returns:

an array of ActivityInput objects

preprocess

protected void preprocess()
                   throws ActivityUserException,
                          ActivityProcessingException,
                          ActivityTerminatedException

Performs any pre-processing required before the iterative part of the activity processing commences.

Specified by:

preprocess in class MatchedIterativeActivity

Throws:

ActivityUserException - if the settings specified by the user prevent processing from completing

ActivityProcessingException - if an internal error prevents processing from completing

ActivityTerminatedException - if activity processing is terminated at an intermediate stage

processIteration

protected void processIteration(java.lang.Object[] iterationData)
                         throws ActivityProcessingException,
                                ActivityTerminatedException,
                                ActivityUserException

Performs an iteration of the activity processing. During this the input blocks should be consumed and the output blocks produced.

Specified by:

processIteration in class MatchedIterativeActivity

Parameters:

iterationData - the data from this iteration

Throws:

ActivityProcessingException - if an internal error prevents processing from completing

ActivityTerminatedException - if activity processing is terminated at an intermediate stage

ActivityUserException - if the settings specified by the user prevent processing from completing

postprocess

protected void postprocess()
                    throws ActivityUserException,
                           ActivityProcessingException,
                           ActivityTerminatedException

Performs any post-processing required after the iterative part of the activity processing has completed. Note that this will not be be invoked if an error occurs during an earlier stage of processing.

Specified by:

postprocess in class MatchedIterativeActivity

Throws:

ActivityUserException - if the settings specified by the user prevent processing from completing

ActivityProcessingException - if an internal error prevents processing from completing

ActivityTerminatedException - if activity processing is terminated at an intermediate stage