Package io.deephaven.pivot

Class PivotTableViewExchangeMarshaller

java.lang.Object

io.deephaven.pivot.PivotTableViewExchangeMarshaller

All Implemented Interfaces:

ExchangeMarshaller

public class PivotTableViewExchangeMarshaller
extends Object
implements ExchangeMarshaller

An ExchangeMarshaller for PivotTableView. Subscriptions are supported, with each subsequent update providing a complete snapshot of the desired viewport. Snapshots are not permitted.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	PivotTableViewExchangeMarshaller.Factory

Constructor Summary

Constructors

Constructor	Description
PivotTableViewExchangeMarshaller(PivotTableViewSubscription.Factory ptvsFactory)

Method Summary

Modifier and Type	Method	Description
boolean	accept(Object export)
static @Nullable RowSet	getColumns(io.deephaven.barrage.flatbuf.BarrageSubscriptionRequest subscriptionRequest)	Helper to retrieve the viewport columns from a subscription request.
int	priority()
void	snapshot(io.deephaven.barrage.flatbuf.BarrageSnapshotRequest snapshotRequest, BarrageSnapshotOptions options, Object export, BarragePerformanceLog.SnapshotMetricsHelper metrics, io.grpc.stub.StreamObserver<BarrageMessageWriter.MessageView> listener, String ticketLogName, BarrageMessageWriter.Factory streamGeneratorFactory)
ExchangeMarshaller.Subscription	subscribe(io.deephaven.barrage.flatbuf.BarrageSubscriptionRequest subscriptionRequest, BarrageSubscriptionOptions options, Object export, io.grpc.stub.StreamObserver<BarrageMessageWriter.MessageView> listener)

Methods inherited from class java.lang.Object

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

Constructor Details

PivotTableViewExchangeMarshaller

public PivotTableViewExchangeMarshaller(PivotTableViewSubscription.Factory ptvsFactory)

Method Details

priority

public int priority()

Specified by:

priority in interface ExchangeMarshaller

accept

public boolean accept(Object export)

Specified by:

accept in interface ExchangeMarshaller

snapshot

public void snapshot(io.deephaven.barrage.flatbuf.BarrageSnapshotRequest snapshotRequest,
 BarrageSnapshotOptions options,
 Object export,
 BarragePerformanceLog.SnapshotMetricsHelper metrics,
 io.grpc.stub.StreamObserver<BarrageMessageWriter.MessageView> listener,
 String ticketLogName,
 BarrageMessageWriter.Factory streamGeneratorFactory)

Specified by:

snapshot in interface ExchangeMarshaller

subscribe

public ExchangeMarshaller.Subscription subscribe(io.deephaven.barrage.flatbuf.BarrageSubscriptionRequest subscriptionRequest,
 BarrageSubscriptionOptions options,
 Object export,
 io.grpc.stub.StreamObserver<BarrageMessageWriter.MessageView> listener)

Specified by:

subscribe in interface ExchangeMarshaller

getColumns

@Nullable
public static @Nullable RowSet getColumns(io.deephaven.barrage.flatbuf.BarrageSubscriptionRequest subscriptionRequest)

Helper to retrieve the viewport columns from a subscription request.