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

Interface TableDataProtocol.RequestHandler

Enclosing class:

TableDataProtocol

public static interface TableDataProtocol.RequestHandler

Interface to a handler that processes table data requests.

Method Summary

Modifier and Type	Method	Description
void	handleAuthenticationRequest(TableDataProtocol.Client peer, long requestKey, io.deephaven.enterprise.auth.AuthToken token)
void	handleColumnFileDataRequest(TableDataProtocol.Client peer, long requestKey, TableKey tableKey, TableLocationKey locationKey, CharSequence columnName, ColumnFileType columnFileType, long startOffset, int minimumLength)
void	handleColumnFileSizeRequest(TableDataProtocol.Client peer, long requestKey, TableKey tableKey, TableLocationKey locationKey, CharSequence columnName, ColumnFileType columnFileType, long requiredSize)
void	handleColumnLocationExistenceRequest(TableDataProtocol.Client peer, long requestKey, TableKey tableKey, TableLocationKey locationKey, CharSequence columnName)
void	handleTableLocationRefreshRequest(TableDataProtocol.Client peer, long requestKey, boolean subscribe, TableKey tableKey, TableLocationKey locationKey)
void	handleTableLocationsRequest(TableDataProtocol.Client peer, long requestKey, boolean subscribe, TableKey tableKey)
void	handleUnsubscribeRequest(TableDataProtocol.Client peer, long requestKey, long requestKeyToUnsubscribe)
void	lostConnection(TableDataProtocol.Client peer)

Method Details

handleUnsubscribeRequest

void handleUnsubscribeRequest(@NotNull
 TableDataProtocol.Client peer,
 long requestKey,
 long requestKeyToUnsubscribe)

handleAuthenticationRequest

void handleAuthenticationRequest(@NotNull
 TableDataProtocol.Client peer,
 long requestKey,
 io.deephaven.enterprise.auth.AuthToken token)

handleTableLocationsRequest

void handleTableLocationsRequest(@NotNull
 TableDataProtocol.Client peer,
 long requestKey,
 boolean subscribe,
 @NotNull
 TableKey tableKey)

handleTableLocationRefreshRequest

void handleTableLocationRefreshRequest(@NotNull
 TableDataProtocol.Client peer,
 long requestKey,
 boolean subscribe,
 @NotNull
 TableKey tableKey,
 @NotNull
 TableLocationKey locationKey)

handleColumnLocationExistenceRequest

void handleColumnLocationExistenceRequest(@NotNull
 TableDataProtocol.Client peer,
 long requestKey,
 @NotNull
 TableKey tableKey,
 @NotNull
 TableLocationKey locationKey,
 @NotNull
 CharSequence columnName)

handleColumnFileSizeRequest

void handleColumnFileSizeRequest(@NotNull
 TableDataProtocol.Client peer,
 long requestKey,
 @NotNull
 TableKey tableKey,
 @NotNull
 TableLocationKey locationKey,
 @NotNull
 CharSequence columnName,
 @NotNull
 ColumnFileType columnFileType,
 long requiredSize)

handleColumnFileDataRequest

void handleColumnFileDataRequest(@NotNull
 TableDataProtocol.Client peer,
 long requestKey,
 @NotNull
 TableKey tableKey,
 @NotNull
 TableLocationKey locationKey,
 @NotNull
 CharSequence columnName,
 @NotNull
 ColumnFileType columnFileType,
 long startOffset,
 int minimumLength)

lostConnection

void lostConnection(@NotNull
 TableDataProtocol.Client peer)