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

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(@NotNull TableDataProtocol.Server peer, long requestKey, long startOffset, int length, @NotNull com.fishlib.io.streams.ByteBufferInputStream dataSource)
void	handleColumnFileSize(@NotNull TableDataProtocol.Server peer, long requestKey, long columnFileSize)
void	handleColumnLocationExistence(@NotNull TableDataProtocol.Server peer, long requestKey, boolean exists, boolean littleEndianByteOrder, boolean symbolTableExists)
void	handleRequestCompletion(@NotNull TableDataProtocol.Server peer, long requestKey)
void	handleRequestRejection(@NotNull TableDataProtocol.Server peer, long requestKey, @NotNull TableDataProtocol.RequestRejectionType requestRejectionType, @NotNull CharSequence rejectText)
void	handleTableLocationAdded(@NotNull TableDataProtocol.Server peer, long requestKey, @NotNull TableLocationKey locationKey)
void	handleTableLocationRemoved(@NotNull TableDataProtocol.Server peer, long requestKey, @NotNull TableLocationKey locationKey)
void	handleTableLocationUpdate(@NotNull TableDataProtocol.Server peer, long requestKey, @NotNull TableLocationState locationState)
void	lostConnection(@NotNull TableDataProtocol.Server peer)

Method Details

handleRequestRejection

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

handleRequestCompletion

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

handleTableLocationAdded

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

handleTableLocationRemoved

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

handleTableLocationUpdate

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

handleColumnLocationExistence

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

handleColumnFileSize

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

handleColumnFileData

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

lostConnection

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