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

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.protocol.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
    sendTableLocationAdded(long requestKey, TableLocationKey locationKey)
     
    void
    sendTableLocationRemoved(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