Package uk.org.ogsadai.activity.io

The classes for reading and writing data during activity processing.

See:
Description

Interface Summary

ActivityInput	The higher-level interface for reading blocks of activity input data, which may encapsulate various forms of data validation.
BlockMaker	A BlockMaker is used to retrieve a sequence of blocks of some type.
BlockReader	The lower-level interface for reading blocks of data directly from an activity input pipe.
BlockWriter	The lower-level interface for writing blocks of data directly into an activity output pipe.
ByteIterator	Interface used to iterate over a sequence of bytes.
ErrorPassingBlockWriter	Interface used to pass errors to a block writer.
InputBlockReader	The interface for reading data from a pipe.
ListIterator	The interface for iterating though a list of blocks read from an activity input.
NestedActivityInput	The higher-level interface for reading nested activity input data, which may encapsulate various forms of data validation.
Pipe	The pipe interface connects a producer and a consumer of data.
PipeFactory	Factory interface for creating pipes.
PipeManager	Manages the pipes that connect activities within a request.
TupleListIterator	The interface for iterating through a list of tuples read from an activity input.

Class Summary

BufferedPipe	A thread-safe pipe with a fixed buffer size.
BufferedPipeFactory	A pipe factory that creates buffered pipes.
ByteArrayByteIterator	Gives a ByteIterator interface to a byte[].
ByteOrCharsReader	Reader that gives access to add in either lists of char[] or byte.
BytesInputStream	An input stream that adapts a block reader containing a stream of byte[] blocks or char[] blocks terminated by a ControlBlock.LIST_END block.
CharArrayByteIterator	Class that gives a ByteIterator interface to access data in a char[].
CharsReader	A reader that adapts a block reader containing a stream of char[] blocks terminated by a ControlBlock.LIST_END block.
CharsWriter	A writer that adapts a block writer producing a stream of char[] blocks.
Connector	Connects a producer of data to a consumer of data.
ControlBlock	Constants class containing pipe control blocks used to indicate the start and end of lists, as well as the end of a stream of data.
ExtendibleBlockReaderWrapper	Wraps a BlockReader with a block reader whose buffer size can be extended.
FullListTupleListIterator	TupleListIterator that wraps a BlockReader.
GrowableInMemoryPipe	A thread-safe pipe that grows indefinitely as blocks of data are added to it.
GrowableInMemoryPipeFactory	Pipe factory that creates growable in-memory pipes.
InputStreamActivityInput	Activity input for reading ActivityInputStream objects.
InputStreamDecorator	Decorates an input stream adding functionality to detect OGSA-DAI termination signals and to translate any errors raised by the decorated input stream.
InputStreamListActivityInput	Activity input for reading lists of uk.org.ogsadai.activity.io.InputStream objects.
InputStreamNestedActivityInput	Nested activity input for reading uk.org.ogsadai.activity.io.InputStream objects.
LateBoundPipe	A pipe that is a wrapper around another pipe which is bound as late as possible by accessing a pipe manager.
LinkedQueuePipe	A thread-safe pipe with a fixed buffer size using separate locks for reads and writes.
LinkedQueuePipeFactory	A pipe factory creating pipes based on linked queue.
LiteralBlockReader	A pipe that contains a list of literal input values.
PipeConnectorCallable	Callable that moves data between a block reader and a block writer.
PrimitiveFilePipe	Pipe implementation that stores the data in a file.
ReaderActivityInput	Activity input for reading uk.org.ogsadai.activity.io.Reader objects.
ReaderDecorator	Decorates a reader adding functionality to detect OGSA-DAI termination signals and to translate any errors raised by the decorated input stream.
ReaderInputStream	InputStream that wraps a Reader.
ReaderListActivityInput	Activity input for reading lists of uk.org.ogsadai.activity.io.Reader objects.
ReaderNestedActivityInput	Nested activity input for reading uk.org.ogsadai.activity.io.Reader objects.
SimpleErrorPassingPipe	Simple pipe wrapper that provides a block writer to which errors can be written that will then be passed to the reader.
SimplePipeManager	A simple pipe manager.
SimpleTupleResultSet	Wrapper than exposes a list of tuples read from an activity input block reader as a ResultSet.
StringActivityInput	Activity input for reading java.lang.String objects.
StringBlockWriter	A block writer which converts every block it reads into a string and appends it to a buffer that can be retrieved later using the getOutputData() method.
StringListActivityInput	Activity input for reading lists of java.lang.String objects.
StringNestedActivityInput	Nested activity input for reading java.lang.String objects.
StringPipeListener	A simple activity listener that outputs details of any activity events that occur to the standard output.
TableMetaDataListActivityInput	Activity input for reading lists of uk.org.ogsadai.converters.databaseschema.TableMetaData objects.
TupleListActivityInput	Activity input for reading lists of uk.org.ogsadai.tuple.Tuple objects.
TupleOptionalListActivityInput	Optional activity input for reading OGSA-DAI Tuple lists.
TupleResultSetActivityInput	Activity input for reading lists of Tuple objects and exposing these as ResultSet.
TupleResultSetMetaData	Wrapper for TupleMetadata to make it appear as ResultSetMetaData.
TypedActivityInput	Activity input for reading blocks of specified type.
TypedListActivityInput	Activity input for reading lists of blocks of specified type.
TypedNestedActivityInput	Nested activity input for reading blocks of specified type.
TypedOptionalActivityInput	Optional activity input for reading blocks of specified type.
TypedOptionalListActivityInput	Optional activity input for reading lists of blocks of a specified type.
Writer	Writer for producing character output data during activity processing.

Exception Summary

ActivityIOException	Raised when an activity encounters a problem during an IO operation.
ActivityPipeProcessingException	Raised when an activity is unable to finish processing due to a problem reading or writing data using an input or output.
BlockMakerException	A uk.org.ogsadai.common.BlockMaker encountered a problem when accessing its blocks.
ByteIteratorException	Exception thrown if an error occurs while reading from a byte iterator.
DataError	Raised by the pipe when the producer has signalled an error and after the last available block has been read by the consumer.
DataErrorIOException	Raised by OGSA-DAI input stream implementations when the pipe has been closed due to an error at the producer.
DuplicateInputNameException	Raised if an activity has multiple inputs with the same name and does not support this case.
DuplicateOutputNameException	Raised if an activity has multiple outputs with the same name and does not support this case.
InvalidInputValueException	Raised if an activity input value is invalid for the activity.
NestedSequencesUnsupportedException	Raised if a block reader cannot handle nested sequences.
PipeClosedException	Raised if a read or write operation is invoked on a pipe that has already been closed.
PipeIOException	Raised if an internal problem occurs during a read of write operation on a pipe.
PipeTerminatedException	Raised if a blocking operation on a pipe is interrupted, indicating that the request containing the pipe is being terminated.
ProcessingIOException	Raised by OGSA-DAI input and output stream implementations when a problem occurs processing data that is not due to incorrect use of OGSA-DAI activities or the provision of unsuitable input data to an activity.
SequenceEndMissingException	Raised if a block reader expects a sequence end marker but encounters a different object.
SequenceStartMissingException	Raised if a sequence start marker was expected when reading from a pipe but a different block was encountered.
TerminatedIOException	Raised by OGSA-DAI input and output stream implementations when a termination signal is detected.
UserIOException	Raised by OGSA-DAI input and output stream implementations when a problem occurs due to incorrect use of OGSA-DAI activities or the provision of unsuitable input data to an activity.

Package uk.org.ogsadai.activity.io Description

The classes for reading and writing data during activity processing.