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

Interface TableDataProtocol.Server

All Superinterfaces:

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

All Known Implementing Classes:

TableDataProtocol.LocalServer, TableDataProtocol.RemoteServer

Enclosing class:

TableDataProtocol

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

Interface to a peer that responds to requests for table data. Used by a remote table data client to represent its servers.

Method Summary

Modifier and Type	Method	Description
void	authenticate()
void	sendColumnFileDataRequest(long requestKey, TableKey tableKey, TableLocationKey locationKey, CharSequence columnName, ColumnFileType columnFileType, long startOffset, int minimumLength)
void	sendColumnFileSizeRequest(long requestKey, TableKey tableKey, TableLocationKey locationKey, CharSequence columnName, ColumnFileType columnFileType, long requiredSize)
void	sendColumnLocationExistenceRequest(long requestKey, TableKey tableKey, TableLocationKey locationKey, CharSequence columnName)
void	sendTableLocationRefreshRequest(long requestKey, boolean subscribe, TableKey tableKey, TableLocationKey locationKey)
void	sendTableLocationsRequest(long requestKey, boolean subscribe, TableKey tableKey)
void	sendUnsubscribeRequest(long requestKey, long requestKeyToUnsubscribe)

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

sendUnsubscribeRequest

void sendUnsubscribeRequest(long requestKey,
 long requestKeyToUnsubscribe)
                     throws IOException

Throws:

IOException

sendTableLocationsRequest

void sendTableLocationsRequest(long requestKey,
 boolean subscribe,
 @NotNull
 TableKey tableKey)
                        throws IOException

Throws:

IOException

sendTableLocationRefreshRequest

void sendTableLocationRefreshRequest(long requestKey,
 boolean subscribe,
 @NotNull
 TableKey tableKey,
 @NotNull
 TableLocationKey locationKey)
                              throws IOException

Throws:

IOException

sendColumnLocationExistenceRequest

void sendColumnLocationExistenceRequest(long requestKey,
 @NotNull
 TableKey tableKey,
 @NotNull
 TableLocationKey locationKey,
 @NotNull
 CharSequence columnName)
                                 throws IOException

Throws:

IOException

sendColumnFileSizeRequest

void sendColumnFileSizeRequest(long requestKey,
 @NotNull
 TableKey tableKey,
 @NotNull
 TableLocationKey locationKey,
 @NotNull
 CharSequence columnName,
 @NotNull
 ColumnFileType columnFileType,
 long requiredSize)
                        throws IOException

Throws:

IOException

sendColumnFileDataRequest

void sendColumnFileDataRequest(long requestKey,
 @NotNull
 TableKey tableKey,
 @NotNull
 TableLocationKey locationKey,
 @NotNull
 CharSequence columnName,
 @NotNull
 ColumnFileType columnFileType,
 long startOffset,
 int minimumLength)
                        throws IOException

Throws:

IOException

authenticate

void authenticate()
           throws IOException

Throws:

IOException