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(@NotNull TableDataProtocol.Client peer, long requestKey, AuthToken token)
void	handleColumnFileDataRequest(@NotNull TableDataProtocol.Client peer, long requestKey, @NotNull TableKey tableKey, @NotNull TableLocationKey locationKey, @NotNull CharSequence columnName, @NotNull ColumnFileType columnFileType, long startOffset, int minimumLength)
void	handleColumnFileSizeRequest(@NotNull TableDataProtocol.Client peer, long requestKey, @NotNull TableKey tableKey, @NotNull TableLocationKey locationKey, @NotNull CharSequence columnName, @NotNull ColumnFileType columnFileType, long requiredSize)
void	handleColumnLocationExistenceRequest(@NotNull TableDataProtocol.Client peer, long requestKey, @NotNull TableKey tableKey, @NotNull TableLocationKey locationKey, @NotNull CharSequence columnName)
void	handleTableLocationRefreshRequest(@NotNull TableDataProtocol.Client peer, long requestKey, boolean subscribe, @NotNull TableKey tableKey, @NotNull TableLocationKey locationKey)
void	handleTableLocationsRequest(@NotNull TableDataProtocol.Client peer, long requestKey, boolean subscribe, @NotNull TableKey tableKey)
void	handleUnsubscribeRequest(@NotNull TableDataProtocol.Client peer, long requestKey, long requestKeyToUnsubscribe)
void	lostConnection(@NotNull TableDataProtocol.Client peer)

Method Details

handleUnsubscribeRequest

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

handleAuthenticationRequest

void handleAuthenticationRequest(@NotNull
 @NotNull TableDataProtocol.Client peer,
 long requestKey,
 AuthToken token)

handleTableLocationsRequest

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

handleTableLocationRefreshRequest

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

handleColumnLocationExistenceRequest

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

handleColumnFileSizeRequest

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

handleColumnFileDataRequest

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

lostConnection

void lostConnection(@NotNull
 @NotNull TableDataProtocol.Client peer)