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

Class TableDataProtocol.LocalClient

java.lang.Object

com.fishlib.net.impl.nio.AbstractInProcessPeer

com.illumon.iris.db.v2.locations.TableDataProtocol.LocalClient

All Implemented Interfaces:

com.fishlib.base.log.LogOutputAppendable, com.fishlib.net.impl.nio.AbstractPeer, TableDataProtocol.Client

Enclosing class:

TableDataProtocol

public static class TableDataProtocol.LocalClient
extends com.fishlib.net.impl.nio.AbstractInProcessPeer
implements TableDataProtocol.Client

Field Summary

Fields inherited from class com.fishlib.net.impl.nio.AbstractInProcessPeer

isShutdown

Constructor Summary

Constructors

Constructor	Description
LocalClient(int peerId, String name)

Method Summary

Modifier and Type	Method	Description
com.fishlib.base.log.LogOutput	append(com.fishlib.base.log.LogOutput logOutput)
void	initialize(TableDataProtocol.LocalServer peer)
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)
void	setRequestHandler(TableDataProtocol.RequestHandler requestHandler)
void	shutdown()
String	toString()

Methods inherited from class com.fishlib.net.impl.nio.AbstractInProcessPeer

flush, flush, getPeerId, isShutdown, maybeFlush, maybeFlush

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.fishlib.net.impl.nio.AbstractPeer

flush, flush, getPeerId, isShutdown, maybeFlush, maybeFlush

Constructor Details

LocalClient

public LocalClient(int peerId, @NotNull String name)

Method Details

setRequestHandler

public void setRequestHandler(@NotNull TableDataProtocol.RequestHandler requestHandler)

initialize

public void initialize(@NotNull TableDataProtocol.LocalServer peer)

shutdown

public void shutdown()

Specified by:

shutdown in interface com.fishlib.net.impl.nio.AbstractPeer

Overrides:

shutdown in class com.fishlib.net.impl.nio.AbstractInProcessPeer

sendRequestRejection

public void sendRequestRejection(long requestKey, @NotNull TableDataProtocol.RequestRejectionType requestRejectionType, @NotNull CharSequence rejectText)

Specified by:

sendRequestRejection in interface TableDataProtocol.Client

sendRequestCompletion

public void sendRequestCompletion(long requestKey)

Specified by:

sendRequestCompletion in interface TableDataProtocol.Client

sendTableLocation

public void sendTableLocation(long requestKey, @NotNull TableLocationKey locationKey)

Specified by:

sendTableLocation in interface TableDataProtocol.Client

sendTableLocationUpdate

public void sendTableLocationUpdate(long requestKey, @NotNull TableLocationState locationState)

Specified by:

sendTableLocationUpdate in interface TableDataProtocol.Client

sendColumnLocationExistence

public void sendColumnLocationExistence(long requestKey, boolean exists, boolean littleEndianByteOrder, boolean symbolTableExists)

Specified by:

sendColumnLocationExistence in interface TableDataProtocol.Client

sendColumnFileSize

public void sendColumnFileSize(long requestKey, long columnFileSize)

Specified by:

sendColumnFileSize in interface TableDataProtocol.Client

sendColumnFileData

public void sendColumnFileData(long requestKey, long startOffset, int length, com.fishlib.io.sched.Message data)

Specified by:

sendColumnFileData in interface TableDataProtocol.Client

toString

public String toString()

Overrides:

toString in class Object

append

public com.fishlib.base.log.LogOutput append(@NotNull com.fishlib.base.log.LogOutput logOutput)

Specified by:

append in interface com.fishlib.base.log.LogOutputAppendable