Package com.illumon.iris.db.v2.locations
Interface TableDataProtocol.Client
- All Superinterfaces:
com.fishlib.net.impl.nio.AbstractPeer
,com.fishlib.base.log.LogOutputAppendable
- All Known Implementing Classes:
TableDataProtocol.LocalClient
,TableDataProtocol.RemoteClient
- Enclosing class:
- TableDataProtocol
public static interface TableDataProtocol.Client
extends com.fishlib.net.impl.nio.AbstractPeer
Interface to a peer that requests table data.
Used by a remote table data server to represent its clients.
-
Method Summary
Modifier and Type Method Description void
sendColumnFileData(long requestKey, long startOffset, int length, com.fishlib.io.sched.Message data)
void
sendColumnFileSize(long requestKey, long columnFileSize)
void
sendColumnLocationExistence(long requestKey, boolean exists, boolean littleEndianByteOrder, boolean symbolTableExists)
void
sendRequestCompletion(long requestKey)
void
sendRequestRejection(long requestKey, TableDataProtocol.RequestRejectionType requestRejectionType, CharSequence rejectText)
void
sendTableLocation(long requestKey, TableLocationKey locationKey)
void
sendTableLocationUpdate(long requestKey, TableLocationState locationState)
-
Method Details
-
sendRequestRejection
void sendRequestRejection(long requestKey, @NotNull TableDataProtocol.RequestRejectionType requestRejectionType, @NotNull CharSequence rejectText) throws IOException- Throws:
IOException
-
sendRequestCompletion
- Throws:
IOException
-
sendTableLocation
- Throws:
IOException
-
sendTableLocationUpdate
void sendTableLocationUpdate(long requestKey, @NotNull TableLocationState locationState) throws IOException- Throws:
IOException
-
sendColumnLocationExistence
void sendColumnLocationExistence(long requestKey, boolean exists, boolean littleEndianByteOrder, boolean symbolTableExists) throws IOException- Throws:
IOException
-
sendColumnFileSize
- Throws:
IOException
-
sendColumnFileData
void sendColumnFileData(long requestKey, long startOffset, int length, com.fishlib.io.sched.Message data) throws IOException- Throws:
IOException
-