Package com.illumon.iris.db.v2.locations.protocol

Interface TableDataProtocol.Client

All Superinterfaces:

io.deephaven.enterprise.comm.impl.nio.AbstractPeer, com.fishlib.base.log.LogOutputAppendable

All Known Implementing Classes:

TableDataProtocol.LocalClient, TableDataProtocol.RemoteClient

Enclosing class:

TableDataProtocol

public static interface TableDataProtocol.Client
extends io.deephaven.enterprise.comm.impl.nio.AbstractPeer

Interface to a peer that requests table data. Used by a remote table data server to represent its clients.

Method Summary

Modifier and Type	Method	Description
void	sendColumnFileData(long requestKey, long startOffset, int length, io.deephaven.enterprise.niowrapper.sched.Message data)
void	sendColumnFileSize(long requestKey, long columnFileSize)
void	sendColumnLocationExistence(long requestKey, boolean exists, boolean littleEndianByteOrder, boolean symbolTableExists)
void	sendRequestCompletion(long requestKey)
void	sendRequestRejection(long requestKey, TableDataProtocol.RequestRejectionType requestRejectionType, CharSequence rejectText)
void	sendTableLocationAdded(long requestKey, TableLocationKey locationKey)
void	sendTableLocationRemoved(long requestKey, TableLocationKey locationKey)
void	sendTableLocationUpdate(long requestKey, TableLocationState locationState)

Methods inherited from interface io.deephaven.enterprise.comm.impl.nio.AbstractPeer

flush, flush, getPeerId, isShutdown, maybeFlush, maybeFlush, shutdown

Methods inherited from interface com.fishlib.base.log.LogOutputAppendable

append

Method Details

sendRequestRejection

void sendRequestRejection(long requestKey,
 @NotNull
 TableDataProtocol.RequestRejectionType requestRejectionType,
 @NotNull
 CharSequence rejectText)
                   throws IOException

Throws:

IOException

sendRequestCompletion

void sendRequestCompletion(long requestKey)
                    throws IOException

Throws:

IOException

sendTableLocationAdded

void sendTableLocationAdded(long requestKey,
 @NotNull
 TableLocationKey locationKey)
                     throws IOException

Throws:

IOException

sendTableLocationRemoved

void sendTableLocationRemoved(long requestKey,
 @NotNull
 TableLocationKey locationKey)
                       throws IOException

Throws:

IOException

sendTableLocationUpdate

void sendTableLocationUpdate(long requestKey,
 @NotNull
 TableLocationState locationState)
                      throws IOException

Throws:

IOException

sendColumnLocationExistence

void sendColumnLocationExistence(long requestKey,
 boolean exists,
 boolean littleEndianByteOrder,
 boolean symbolTableExists)
                          throws IOException

Throws:

IOException

sendColumnFileSize

void sendColumnFileSize(long requestKey,
 long columnFileSize)
                 throws IOException

Throws:

IOException

sendColumnFileData

void sendColumnFileData(long requestKey,
 long startOffset,
 int length,
 io.deephaven.enterprise.niowrapper.sched.Message data)
                 throws IOException

Throws:

IOException