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

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	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)

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)