org.das2.qstream.filter.ReduceFilter

Reduce packets of the same type by combining packets together. Currently this just does linear averages of the data, but this can easily be extended to support other combinations, such as min and max.

ReduceFilter( )


packet

packet( org.das2.qstream.PacketDescriptor pd, java.nio.ByteBuffer data ) → void

accumulate data into packets by reducing them.

Parameters

pd - a PacketDescriptor
data - a ByteBuffer

Returns:

void (returns nothing)

[search for examples] [view on GitHub] [view on old javadoc] [view source]


packetDescriptor

packetDescriptor( org.das2.qstream.PacketDescriptor pd ) → void

Parameters

pd - a PacketDescriptor

Returns:

void (returns nothing)

[search for examples] [view on GitHub] [view on old javadoc] [view source]


setCadence

setCadence( Datum cadence ) → void

set the cadence to reduce to target the data. This should be convertible to seconds. Note we assume all packets have the same offset units (e.g. microseconds).

Parameters

cadence - a Datum

Returns:

void (returns nothing)

[search for examples] [view on GitHub] [view on old javadoc] [view source]


setSink

setSink( org.das2.qstream.StreamHandler sink ) → void

set the sink for the stream components as they are processed.

Parameters

sink - a StreamHandler

Returns:

void (returns nothing)

[search for examples] [view on GitHub] [view on old javadoc] [view source]


streamClosed

streamClosed( org.das2.qstream.StreamDescriptor sd ) → void

Parameters

sd - a StreamDescriptor

Returns:

void (returns nothing)

[search for examples] [view on GitHub] [view on old javadoc] [view source]


streamComment

streamComment( org.das2.qstream.StreamComment se ) → void

Parameters

se - a StreamComment

Returns:

void (returns nothing)

[search for examples] [view on GitHub] [view on old javadoc] [view source]


streamDescriptor

streamDescriptor( org.das2.qstream.StreamDescriptor sd ) → void

Parameters

sd - a StreamDescriptor

Returns:

void (returns nothing)

[search for examples] [view on GitHub] [view on old javadoc] [view source]


streamException

streamException( org.das2.qstream.StreamException se ) → void

Parameters

se - a StreamException

Returns:

void (returns nothing)

[search for examples] [view on GitHub] [view on old javadoc] [view source]