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

Class TableDataProtocol.LocalServer

java.lang.Object

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

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

All Implemented Interfaces:

com.fishlib.base.log.LogOutputAppendable, TableDataProtocol.Server, AbstractPeer

Enclosing class:

TableDataProtocol

public static class TableDataProtocol.LocalServer
extends AbstractInProcessPeer
implements TableDataProtocol.Server

Field Summary

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

isShutdown

Constructor Summary

Constructors

Constructor	Description
LocalServer(int peerId, @NotNull String name)

Method Summary

Modifier and Type	Method	Description
com.fishlib.base.log.LogOutput	append(@NotNull com.fishlib.base.log.LogOutput logOutput)
void	authenticate()
void	initialize(@NotNull TableDataProtocol.LocalClient peer)
void	sendColumnFileDataRequest(long requestKey, @NotNull TableKey tableKey, @NotNull TableLocationKey locationKey, @NotNull CharSequence columnName, @NotNull ColumnFileType columnFileType, long startOffset, int minimumLength)
void	sendColumnFileSizeRequest(long requestKey, @NotNull TableKey tableKey, @NotNull TableLocationKey locationKey, @NotNull CharSequence columnName, @NotNull ColumnFileType columnFileType, long requiredSize)
void	sendColumnLocationExistenceRequest(long requestKey, @NotNull TableKey tableKey, @NotNull TableLocationKey locationKey, @NotNull CharSequence columnName)
void	sendTableLocationRefreshRequest(long requestKey, boolean subscribe, @NotNull TableKey tableKey, @NotNull TableLocationKey locationKey)
void	sendTableLocationsRequest(long requestKey, boolean subscribe, @NotNull TableKey tableKey)
void	sendUnsubscribeRequest(long requestKey, long requestKeyToUnsubscribe)
void	setResponseHandler(@NotNull TableDataProtocol.ResponseHandler responseHandler)
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

LocalServer

public LocalServer(int peerId,
 @NotNull
 @NotNull String name)

Method Details

setResponseHandler

public void setResponseHandler(@NotNull
 @NotNull TableDataProtocol.ResponseHandler responseHandler)

initialize

public void initialize(@NotNull
 @NotNull TableDataProtocol.LocalClient peer)

shutdown

public void shutdown()

Specified by:

shutdown in interface AbstractPeer

Overrides:

shutdown in class AbstractInProcessPeer

sendUnsubscribeRequest

public void sendUnsubscribeRequest(long requestKey,
 long requestKeyToUnsubscribe)

Specified by:

sendUnsubscribeRequest in interface TableDataProtocol.Server

sendTableLocationsRequest

public void sendTableLocationsRequest(long requestKey,
 boolean subscribe,
 @NotNull
 @NotNull TableKey tableKey)

Specified by:

sendTableLocationsRequest in interface TableDataProtocol.Server

sendTableLocationRefreshRequest

public void sendTableLocationRefreshRequest(long requestKey,
 boolean subscribe,
 @NotNull
 @NotNull TableKey tableKey,
 @NotNull
 @NotNull TableLocationKey locationKey)

Specified by:

sendTableLocationRefreshRequest in interface TableDataProtocol.Server

sendColumnLocationExistenceRequest

public void sendColumnLocationExistenceRequest(long requestKey,
 @NotNull
 @NotNull TableKey tableKey,
 @NotNull
 @NotNull TableLocationKey locationKey,
 @NotNull
 @NotNull CharSequence columnName)

Specified by:

sendColumnLocationExistenceRequest in interface TableDataProtocol.Server

sendColumnFileSizeRequest

public void sendColumnFileSizeRequest(long requestKey,
 @NotNull
 @NotNull TableKey tableKey,
 @NotNull
 @NotNull TableLocationKey locationKey,
 @NotNull
 @NotNull CharSequence columnName,
 @NotNull
 @NotNull ColumnFileType columnFileType,
 long requiredSize)

Specified by:

sendColumnFileSizeRequest in interface TableDataProtocol.Server

sendColumnFileDataRequest

public void sendColumnFileDataRequest(long requestKey,
 @NotNull
 @NotNull TableKey tableKey,
 @NotNull
 @NotNull TableLocationKey locationKey,
 @NotNull
 @NotNull CharSequence columnName,
 @NotNull
 @NotNull ColumnFileType columnFileType,
 long startOffset,
 int minimumLength)

Specified by:

sendColumnFileDataRequest in interface TableDataProtocol.Server

toString

public String toString()

Overrides:

toString in class Object

append

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

Specified by:

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

authenticate

public void authenticate()

Specified by:

authenticate in interface TableDataProtocol.Server