Package org.vast.swe

Class BinaryDataParser

java.lang.Object

org.vast.swe.DataTreeVisitor

org.vast.swe.AbstractDataParser

org.vast.swe.BinaryDataParser

All Implemented Interfaces:

DataStreamParser

public class BinaryDataParser
extends AbstractDataParser

Parses CDM binary data stream using the data components structure and the binary encoding information.

Since:

Nov 22, 2005

Nested Class Summary

Nested classes/interfaces inherited from class org.vast.swe.DataTreeVisitor

DataTreeVisitor.Record

Field Summary

Fields

Modifier and Type	Field	Description
protected boolean	componentEncodingResolved
protected DataInputExt	dataInput
protected InputStream	input

Fields inherited from class org.vast.swe.AbstractDataParser

CHOICE_ERROR, dataTypeUtils, renewDataBlock, stopParsing, STREAM_ERROR

Fields inherited from class org.vast.swe.DataTreeVisitor

componentStack, currentRecord, dataComponents, dataEncoding, dataHandler, endOfArray, errorHandler, newBlock, parentArray, parentArrayIndex, parsing, rawHandler

Constructor Summary

Constructors

Constructor	Description
BinaryDataParser()

Method Summary

Modifier and Type	Method	Description
void	close()
protected void	initBlockReader(DataComponent blockComponent, BinaryBlockImpl binaryOpts)
boolean	moreData()	Checks if more data is available from the stream
DataBlock	parse()
void	parse(InputStream inputStream)
protected void	processAtom(ScalarComponent scalarComponent)	Processes a scalar component
protected boolean	processBlock(DataComponent blockComponent)	Processes an aggregate component
void	reset()	Reset the parser before parsing a new tuple
protected void	resolveComponentEncodings()	Maps a given scalar component to the corresponding BinaryValue object containing binary encoding information.
void	setInput(InputStream inputStream)

Methods inherited from class org.vast.swe.AbstractDataParser

parse, parse, parseNextBlock, setDataComponents, setRenewDataBlock, stop

Methods inherited from class org.vast.swe.DataTreeVisitor

endDataBlock, getDataComponents, getDataEncoding, getDataHandler, getErrorHandler, getRawDataHandler, isEndOfDataBlock, processNextElement, setDataEncoding, setDataHandler, setErrorHandler, setParentArray, setRawDataHandler

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.vast.cdm.common.DataStreamParser

getDataComponents, getDataEncoding, getDataHandler, getErrorHandler, getRawDataHandler, setDataEncoding, setDataHandler, setErrorHandler, setParentArray, setRawDataHandler

Field Details

dataInput

protected DataInputExt dataInput

input

protected InputStream input

componentEncodingResolved

protected boolean componentEncodingResolved

Constructor Details

BinaryDataParser

public BinaryDataParser()

Method Details

setInput

public void setInput(InputStream inputStream)
              throws IOException

Throws:

IOException

parse

public void parse(InputStream inputStream)
           throws IOException

Throws:

IOException

parse

public DataBlock parse()
                throws IOException

Throws:

IOException

reset

public void reset()

Description copied from class: DataTreeVisitor

Reset the parser before parsing a new tuple

Specified by:

reset in interface DataStreamParser

Overrides:

reset in class AbstractDataParser

resolveComponentEncodings

protected void resolveComponentEncodings()
                                  throws CDMException

Maps a given scalar component to the corresponding BinaryValue object containing binary encoding information. This also forces the DataValues primitive type to be the same as the ones specified in the binary encoding section.

Throws:

CDMException

initBlockReader

protected void initBlockReader(DataComponent blockComponent,
 BinaryBlockImpl binaryOpts)
                        throws CDMException

Throws:

CDMException

moreData

public boolean moreData()
                 throws IOException

Checks if more data is available from the stream

Specified by:

moreData in class AbstractDataParser

Returns:

true if more data needs to be parsed, false otherwise

Throws:

IOException

processAtom

protected void processAtom(ScalarComponent scalarComponent)
                    throws IOException

Description copied from class: DataTreeVisitor

Processes a scalar component

Specified by:

processAtom in class DataTreeVisitor

Throws:

IOException

processBlock

protected boolean processBlock(DataComponent blockComponent)
                        throws IOException

Description copied from class: DataTreeVisitor

Processes an aggregate component

Specified by:

processBlock in class DataTreeVisitor

Returns:

true if children should be processed, false otherwise

Throws:

IOException

close

public void close()
           throws IOException

Throws:

IOException