org.vast.swe

Class FilteredWriter

java.lang.Object

org.vast.swe.DataTreeVisitor

org.vast.swe.AbstractDataWriter

org.vast.swe.FilteredWriter

All Implemented Interfaces:

DataStreamWriter

public class FilteredWriter
extends AbstractDataWriter

Delegating writer for writing only the selected components.
This is used to implement filtering by observed property in SOS.

Since:

Oct 9, 2015

Author:

Alex Robin

Nested Class Summary

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

DataTreeVisitor.Record

Field Summary

Fields inherited from class org.vast.swe.AbstractDataWriter

CHOICE_ERROR, dataTypeUtils, NO_HANDLER_ERROR, stopWriting, 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 and Description
FilteredWriter(AbstractDataWriter writer, Collection<String> enabledDefUris)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
protected void	endDataBlock()
void	flush()
protected void	processAtom(ScalarComponent component)
protected boolean	processBlock(DataComponent component) Process an aggregate component
void	reset() Reset the parser before parsing a new tuple
void	setDataComponents(DataComponent dataInfo)
void	setDataEncoding(DataEncoding dataEncoding)
void	setOutput(OutputStream os)

Methods inherited from class org.vast.swe.AbstractDataWriter

stop, write, write

Methods inherited from class org.vast.swe.DataTreeVisitor

getDataComponents, getDataEncoding, getDataHandler, getErrorHandler, getRawDataHandler, isEndOfDataBlock, processNextElement, 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.DataStreamWriter

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

Constructor Detail

FilteredWriter

public FilteredWriter(AbstractDataWriter writer,
              Collection<String> enabledDefUris)

Method Detail

processAtom

protected void processAtom(ScalarComponent component)
                    throws IOException

Specified by:

processAtom in class AbstractDataWriter

Throws:

IOException

processBlock

protected boolean processBlock(DataComponent component)
                        throws IOException

Description copied from class: DataTreeVisitor

Process an aggregate component

Specified by:

processBlock in class AbstractDataWriter

Returns:

true if children should be processed, false otherwise

Throws:

IOException

endDataBlock

protected void endDataBlock()
                     throws Exception

Overrides:

endDataBlock in class DataTreeVisitor

Throws:

Exception

setDataComponents

public void setDataComponents(DataComponent dataInfo)

Specified by:

setDataComponents in interface DataStreamWriter

Overrides:

setDataComponents in class AbstractDataWriter

setDataEncoding

public void setDataEncoding(DataEncoding dataEncoding)

Specified by:

setDataEncoding in interface DataStreamWriter

Overrides:

setDataEncoding in class DataTreeVisitor

setOutput

public void setOutput(OutputStream os)
               throws IOException

Specified by:

setOutput in interface DataStreamWriter

Specified by:

setOutput in class AbstractDataWriter

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface DataStreamWriter

Specified by:

close in class AbstractDataWriter

Throws:

IOException

flush

public void flush()
           throws IOException

Specified by:

flush in interface DataStreamWriter

Specified by:

flush in class AbstractDataWriter

Throws:

IOException

reset

public void reset()

Description copied from class: DataTreeVisitor

Reset the parser before parsing a new tuple

Specified by:

reset in interface DataStreamWriter

Overrides:

reset in class DataTreeVisitor