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

Interface TableDataProtocol.ResponseHandler

Enclosing class:

TableDataProtocol

public static interface TableDataProtocol.ResponseHandler

Interface to a handler that processes table data responses.

Method Summary

Modifier and Type	Method	Description
void	handleColumnFileData(TableDataProtocol.Server peer, long requestKey, long startOffset, int length, com.fishlib.io.streams.ByteBufferInputStream dataSource)
void	handleColumnFileSize(TableDataProtocol.Server peer, long requestKey, long columnFileSize)
void	handleColumnLocationExistence(TableDataProtocol.Server peer, long requestKey, boolean exists, boolean littleEndianByteOrder, boolean symbolTableExists)
void	handleRequestCompletion(TableDataProtocol.Server peer, long requestKey)
void	handleRequestRejection(TableDataProtocol.Server peer, long requestKey, TableDataProtocol.RequestRejectionType requestRejectionType, CharSequence rejectText)
void	handleTableLocation(TableDataProtocol.Server peer, long requestKey, TableLocationKey locationKey)
void	handleTableLocationUpdate(TableDataProtocol.Server peer, long requestKey, TableLocationState locationState)
void	lostConnection(TableDataProtocol.Server peer)

Method Details

handleRequestRejection

void handleRequestRejection(@NotNull TableDataProtocol.Server peer, long requestKey, @NotNull TableDataProtocol.RequestRejectionType requestRejectionType, @NotNull CharSequence rejectText)

handleRequestCompletion

void handleRequestCompletion(@NotNull TableDataProtocol.Server peer, long requestKey)

handleTableLocation

void handleTableLocation(@NotNull TableDataProtocol.Server peer, long requestKey, @NotNull TableLocationKey locationKey)

handleTableLocationUpdate

void handleTableLocationUpdate(@NotNull TableDataProtocol.Server peer, long requestKey, @NotNull TableLocationState locationState)

handleColumnLocationExistence

void handleColumnLocationExistence(@NotNull TableDataProtocol.Server peer, long requestKey, boolean exists, boolean littleEndianByteOrder, boolean symbolTableExists)

handleColumnFileSize

void handleColumnFileSize(@NotNull TableDataProtocol.Server peer, long requestKey, long columnFileSize)

handleColumnFileData

void handleColumnFileData(@NotNull TableDataProtocol.Server peer, long requestKey, long startOffset, int length, @NotNull com.fishlib.io.streams.ByteBufferInputStream dataSource)

lostConnection

void lostConnection(@NotNull TableDataProtocol.Server peer)