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

Interface TableDataProtocol.Server

All Superinterfaces:

com.fishlib.net.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 com.fishlib.net.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 com.fishlib.net.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