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

Class TableDataProtocol.RemoteClient

java.lang.Object

io.deephaven.enterprise.niowrapper.sched.NullIOHandler

io.deephaven.enterprise.comm.impl.nio.AbstractRemotePeer

io.deephaven.enterprise.comm.impl.nio.AbstractReadaheadRemotePeer

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

All Implemented Interfaces:

com.fishlib.base.log.LogOutputAppendable, TableDataProtocol.Client, io.deephaven.enterprise.comm.impl.nio.AbstractPeer, io.deephaven.enterprise.niowrapper.sched.IOHandler

Enclosing class:

TableDataProtocol

public static class TableDataProtocol.RemoteClient
extends io.deephaven.enterprise.comm.impl.nio.AbstractReadaheadRemotePeer
implements TableDataProtocol.Client

Field Summary

Fields inherited from class io.deephaven.enterprise.comm.impl.nio.AbstractRemotePeer

clock, peerId

Constructor Summary

Constructors

Constructor	Description
RemoteClient(int peerId, String name, io.deephaven.enterprise.niowrapper.sched.IOJob job, com.fishlib.io.logger.Logger log, io.deephaven.enterprise.niowrapper.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(io.deephaven.enterprise.niowrapper.sched.IOJob job)
void	initialize(TableDataProtocol.RequestHandler requestHandler)
protected void	parse(io.deephaven.enterprise.comm.impl.nio.WObjectReader reader)
void	sendColumnFileData(long requestKey, long startOffset, int length, io.deephaven.enterprise.niowrapper.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 io.deephaven.enterprise.comm.impl.nio.AbstractReadaheadRemotePeer

getPeerId, handleIncoming

Methods inherited from class io.deephaven.enterprise.comm.impl.nio.AbstractRemotePeer

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

Methods inherited from class io.deephaven.enterprise.niowrapper.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 io.deephaven.enterprise.comm.impl.nio.AbstractPeer

flush, flush, getPeerId, isShutdown, maybeFlush, maybeFlush, shutdown

Constructor Details

RemoteClient

public RemoteClient(int peerId,
 String name,
 io.deephaven.enterprise.niowrapper.sched.IOJob job,
 com.fishlib.io.logger.Logger log,
 io.deephaven.enterprise.niowrapper.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
 io.deephaven.enterprise.comm.impl.nio.WObjectReader reader)
              throws IOException

Specified by:

parse in class io.deephaven.enterprise.comm.impl.nio.AbstractReadaheadRemotePeer

Throws:

IOException

dispatch

protected void dispatch(boolean bufferComplete)

Specified by:

dispatch in class io.deephaven.enterprise.comm.impl.nio.AbstractReadaheadRemotePeer

endJob

public void endJob(@NotNull
 io.deephaven.enterprise.niowrapper.sched.IOJob job)

Specified by:

endJob in interface io.deephaven.enterprise.niowrapper.sched.IOHandler

Specified by:

endJob in class io.deephaven.enterprise.comm.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

sendTableLocationAdded

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

Specified by:

sendTableLocationAdded 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
 io.deephaven.enterprise.niowrapper.sched.Message data)
                        throws IOException

Specified by:

sendColumnFileData in interface TableDataProtocol.Client

Throws:

IOException

sendTableLocationRemoved

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

Specified by:

sendTableLocationRemoved in interface TableDataProtocol.Client

Throws:

IOException

toString

public String toString()

Overrides:

toString in class io.deephaven.enterprise.comm.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 io.deephaven.enterprise.comm.impl.nio.AbstractRemotePeer