software.chronicle.datagrid.internal.queue

Class QueueWrappingColumnView<K,V>

java.lang.Object

software.chronicle.datagrid.internal.queue.QueueWrappingColumnView<K,V>

All Implemented Interfaces:

ColumnViewInternal, QueueColumnView

public final class QueueWrappingColumnView<K,V>
extends Object
implements QueueColumnView

Nested Class Summary

Nested classes/interfaces inherited from interface software.chronicle.datagrid.internal.column.ColumnViewInternal

ColumnViewInternal.DOp, ColumnViewInternal.MarshableFilter, ColumnViewInternal.MarshableOrderBy, ColumnViewInternal.SortedFilter

Constructor Summary

Constructors

Constructor and Description
QueueWrappingColumnView(RequestContext requestContext, Asset asset, @NotNull QueueView<String,V> queueView)

Method Summary

Modifier and Type	Method and Description
Asset	asset()
boolean	canDeleteRows()
int	changedRow(@NotNull Map<String,Object> row, @NotNull Map<String,Object> oldRow) used to add, update and delete rows called when ever the user modify the cells and the data changes
@NotNull List<Column>	columns()
boolean	containsRowWithKey(@NotNull List keys)
@Nullable Predicate<QueueView.Excerpt<String,V>>	filter(@Nullable List<ColumnViewInternal.MarshableFilter> filters)
@NotNull ClosableIterator<ChronicleQueueRow>	iterator(@NotNull ColumnViewInternal.SortedFilter filters)
@Nullable ObjectSubscription	objectSubscription()
void	registerChangeListener(@NotNull Runnable r) called whenever some data in the underlying structure has changed and hence the visual layer has to be refreshed
int	rowCount(@NotNull ColumnViewInternal.SortedFilter filters)

Methods inherited from class java.lang.Object

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

Methods inherited from interface software.chronicle.datagrid.internal.column.ColumnViewInternal

predicate, toPredicate

Constructor Detail

QueueWrappingColumnView

public QueueWrappingColumnView(RequestContext requestContext,
                               Asset asset,
                               @NotNull
                               @NotNull QueueView<String,V> queueView)

Method Detail

registerChangeListener

public void registerChangeListener(@NotNull
                                   @NotNull Runnable r)

Description copied from interface: ColumnViewInternal

called whenever some data in the underlying structure has changed and hence the visual layer has to be refreshed

Specified by:

registerChangeListener in interface ColumnViewInternal

Parameters:

r - to refresh the visual layer

iterator

@NotNull
public @NotNull ClosableIterator<ChronicleQueueRow> iterator(@NotNull
                                                                      @NotNull ColumnViewInternal.SortedFilter filters)

Specified by:

iterator in interface ColumnViewInternal

containsRowWithKey

public boolean containsRowWithKey(@NotNull
                                  @NotNull List keys)

Specified by:

containsRowWithKey in interface ColumnViewInternal

objectSubscription

@Nullable
public @Nullable ObjectSubscription objectSubscription()

Specified by:

objectSubscription in interface ColumnViewInternal

asset

public Asset asset()

Specified by:

asset in interface ColumnViewInternal

columns

@NotNull
public @NotNull List<Column> columns()

Specified by:

columns in interface ColumnViewInternal

canDeleteRows

public boolean canDeleteRows()

Specified by:

canDeleteRows in interface ColumnViewInternal

changedRow

public int changedRow(@NotNull
                      @NotNull Map<String,Object> row,
                      @NotNull
                      @NotNull Map<String,Object> oldRow)

Description copied from interface: ColumnViewInternal

used to add, update and delete rows called when ever the user modify the cells and the data changes

Specified by:

changedRow in interface ColumnViewInternal

Parameters:

row - if row is empty, the row is removed, based on the key in oldRow

oldRow - if oldRow is empty, the row is added , based on the key in row

Returns:

the number of rows effected

filter

@Nullable
public @Nullable Predicate<QueueView.Excerpt<String,V>> filter(@Nullable
                                                                         @Nullable List<ColumnViewInternal.MarshableFilter> filters)

rowCount

public int rowCount(@NotNull
                    @NotNull ColumnViewInternal.SortedFilter filters)

Specified by:

rowCount in interface ColumnViewInternal

Parameters:

filters - if sortedFilter == null or empty all the total number of rows is returned

Returns:

the number of rows the matches this query