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

Interface TableDataProtocol.Client

All Superinterfaces:

AbstractPeer, com.fishlib.base.log.LogOutputAppendable

All Known Implementing Classes:

TableDataProtocol.LocalClient, TableDataProtocol.RemoteClient

Enclosing class:

TableDataProtocol

public static interface TableDataProtocol.Client
extends 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, 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, @NotNull TableDataProtocol.RequestRejectionType requestRejectionType, @NotNull CharSequence rejectText)
void	sendTableLocationAdded(long requestKey, @NotNull TableLocationKey locationKey)
void	sendTableLocationRemoved(long requestKey, @NotNull TableLocationKey locationKey)
void	sendTableLocationUpdate(long requestKey, @NotNull 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
 @NotNull TableDataProtocol.RequestRejectionType requestRejectionType,
 @NotNull
 @NotNull CharSequence rejectText)
                   throws IOException

Throws:

IOException

sendRequestCompletion

void sendRequestCompletion(long requestKey)
                    throws IOException

Throws:

IOException

sendTableLocationAdded

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

Throws:

IOException

sendTableLocationRemoved

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

Throws:

IOException

sendTableLocationUpdate

void sendTableLocationUpdate(long requestKey,
 @NotNull
 @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,
 Message data)
                 throws IOException

Throws:

IOException