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

Class UpdateCoalescer

java.lang.Object

io.deephaven.engine.table.impl.util.UpdateCoalescer

All Implemented Interfaces:

SafeCloseable, AutoCloseable

public class UpdateCoalescer
extends Object
implements SafeCloseable

Helper utility for coalescing multiple updates.

Owns every RowSet it allocates, so it must be closed. Calling coalesce() hands added, removed and modified to the update it returns, which the caller must then release; whatever is left belongs to this object and close() frees it. A coalescer that is closed without being coalesced therefore releases everything, which is what makes it safe to abandon one.

Field Summary

Fields

Modifier and Type	Field	Description
final WritableRowSet	added
final WritableRowSet	modified
ModifiedColumnSet	modifiedColumnSet
final WritableRowSet	removed
RowSetShiftData	shifted

Constructor Summary

Constructors

Constructor	Description
UpdateCoalescer(RowSet rowSet, TableUpdate update)

Method Summary

Modifier and Type	Method	Description
void	close()
TableUpdate	coalesce()	The updates seen so far as one.
UpdateCoalescer	update(TableUpdate update)

Methods inherited from class java.lang.Object

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

Field Details

added

public final WritableRowSet added

removed

public final WritableRowSet removed

modified

public final WritableRowSet modified

shifted

public RowSetShiftData shifted

modifiedColumnSet

public ModifiedColumnSet modifiedColumnSet

Constructor Details

UpdateCoalescer

public UpdateCoalescer(RowSet rowSet,
 TableUpdate update)

Method Details

coalesce

public TableUpdate coalesce()

The updates seen so far as one. Ownership of added, removed and modified passes to the result, so the caller must release it; close() leaves them alone from here on. Because that ownership can only be given away once, this may be called at most once.

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface SafeCloseable

update

public UpdateCoalescer update(TableUpdate update)