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

Class TableDataProtocol.LocalClient

java.lang.Object

io.deephaven.enterprise.comm.impl.nio.AbstractInProcessPeer

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

All Implemented Interfaces:

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

Enclosing class:

TableDataProtocol

public static class TableDataProtocol.LocalClient
extends io.deephaven.enterprise.comm.impl.nio.AbstractInProcessPeer
implements TableDataProtocol.Client

Field Summary

Fields inherited from class io.deephaven.enterprise.comm.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, 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)
void	setRequestHandler(TableDataProtocol.RequestHandler requestHandler)
void	shutdown()
String	toString()

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

Overrides:

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

sendTableLocationAdded

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

Specified by:

sendTableLocationAdded in interface TableDataProtocol.Client

sendTableLocationRemoved

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

Specified by:

sendTableLocationRemoved 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,
 io.deephaven.enterprise.niowrapper.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