Package io.deephaven.engine.table.impl.util

Class RowSetShiftDataExpander

java.lang.Object

io.deephaven.engine.table.impl.util.RowSetShiftDataExpander

All Implemented Interfaces:

SafeCloseable, AutoCloseable

public class RowSetShiftDataExpander
extends Object
implements SafeCloseable

Converts table updates used for standard table update listeners's into row sets compatible with legacy-style shift-oblivious listeners by expanding keyspace shifts. Using this is almost always less efficient than using the TableUpdate directly.

Field Summary

Fields

Modifier and Type	Field	Description
static final RowSetShiftDataExpander	EMPTY	Immutable, re-usable RowSetShiftDataExpander for an empty set of changes.

Constructor Summary

Constructors

Constructor	Description
RowSetShiftDataExpander(TableUpdate update, TrackingRowSet sourceRowSet)	Generates the backwards compatible ARM from an ARMS update.

Method Summary

Modifier and Type	Method	Description
void	close()
RowSet	getAdded()	Fetch the resulting RowSet of added values.
RowSet	getModified()	Fetch the resulting RowSet of modified values.
RowSet	getRemoved()	Fetch the resulting RowSet of removed values.

Methods inherited from class java.lang.Object

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

Field Details

EMPTY

public static final RowSetShiftDataExpander EMPTY

Immutable, re-usable RowSetShiftDataExpander for an empty set of changes.

Constructor Details

RowSetShiftDataExpander

public RowSetShiftDataExpander(TableUpdate update,
 TrackingRowSet sourceRowSet)

Generates the backwards compatible ARM from an ARMS update.

Parameters:

update - The upstream update.

Method Details

getAdded

public RowSet getAdded()

Fetch the resulting RowSet of added values.

Returns:

added RowSet

getRemoved

public RowSet getRemoved()

Fetch the resulting RowSet of removed values.

Returns:

removed RowSet

getModified

public RowSet getModified()

Fetch the resulting RowSet of modified values.

Returns:

modified RowSet

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface SafeCloseable