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

Class TableDataProtocol.RemoteClient

java.lang.Object

com.fishlib.io.sched.NullIOHandler

com.fishlib.net.impl.nio.AbstractRemotePeer

com.fishlib.net.impl.nio.AbstractReadaheadRemotePeer

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

All Implemented Interfaces:

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

Enclosing class:

TableDataProtocol

public static class TableDataProtocol.RemoteClient
extends com.fishlib.net.impl.nio.AbstractReadaheadRemotePeer
implements TableDataProtocol.Client

Field Summary

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

clock, peerId

Constructor Summary

Constructors

Constructor	Description
RemoteClient(int peerId, String name, com.fishlib.io.sched.IOJob job, com.fishlib.io.logger.Logger log, com.fishlib.io.sched.PooledMessage.Pool pool, com.fishlib.base.clock.Clock clock)

Method Summary

Modifier and Type	Method	Description
com.fishlib.base.log.LogOutput	append(com.fishlib.base.log.LogOutput logOutput)
protected void	dispatch(boolean bufferComplete)
void	endJob(com.fishlib.io.sched.IOJob job)
void	initialize(TableDataProtocol.RequestHandler requestHandler)
protected void	parse(com.fishlib.net.impl.nio.WObjectReader reader)
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)
String	toString()

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

getPeerId, handleIncoming

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

addMessage, flush, flush, getByteCount, getJob, getLog, getOutput, getReader, getWriter, isShutdown, maybeFlush, maybeFlush, shutdown

Methods inherited from class com.fishlib.io.sched.NullIOHandler

handleEOF, handleError, handleOutgoing, handleTimeout, startJob

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, shutdown

Constructor Details

RemoteClient

public RemoteClient(int peerId, String name, com.fishlib.io.sched.IOJob job, com.fishlib.io.logger.Logger log, com.fishlib.io.sched.PooledMessage.Pool pool, com.fishlib.base.clock.Clock clock)

Method Details

initialize

public void initialize(@NotNull TableDataProtocol.RequestHandler requestHandler)

parse

protected void parse(@NotNull com.fishlib.net.impl.nio.WObjectReader reader) throws IOException

Specified by:

parse in class com.fishlib.net.impl.nio.AbstractReadaheadRemotePeer

Throws:

IOException

dispatch

protected void dispatch(boolean bufferComplete)

Specified by:

dispatch in class com.fishlib.net.impl.nio.AbstractReadaheadRemotePeer

endJob

public void endJob(@NotNull com.fishlib.io.sched.IOJob job)

Specified by:

endJob in interface com.fishlib.io.sched.IOHandler

Specified by:

endJob in class com.fishlib.net.impl.nio.AbstractRemotePeer

sendRequestRejection

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

Specified by:

sendRequestRejection in interface TableDataProtocol.Client

Throws:

IOException

sendRequestCompletion

public void sendRequestCompletion(long requestKey) throws IOException

Specified by:

sendRequestCompletion in interface TableDataProtocol.Client

Throws:

IOException

sendTableLocation

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

Specified by:

sendTableLocation in interface TableDataProtocol.Client

Throws:

IOException

sendTableLocationUpdate

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

Specified by:

sendTableLocationUpdate in interface TableDataProtocol.Client

Throws:

IOException

sendColumnLocationExistence

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

Specified by:

sendColumnLocationExistence in interface TableDataProtocol.Client

Throws:

IOException

sendColumnFileSize

public void sendColumnFileSize(long requestKey, long columnFileSize) throws IOException

Specified by:

sendColumnFileSize in interface TableDataProtocol.Client

Throws:

IOException

sendColumnFileData

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

Specified by:

sendColumnFileData in interface TableDataProtocol.Client

Throws:

IOException

toString

public String toString()

Overrides:

toString in class com.fishlib.net.impl.nio.AbstractRemotePeer

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

Overrides:

append in class com.fishlib.net.impl.nio.AbstractRemotePeer