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, io.deephaven.enterprise.comm.impl.nio.AbstractPeer

Enclosing class:

TableDataProtocol

public static class TableDataProtocol.LocalServer
extends io.deephaven.enterprise.comm.impl.nio.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, String name)

Method Summary

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

Method Details

setResponseHandler

public void setResponseHandler(@NotNull
 TableDataProtocol.ResponseHandler responseHandler)

initialize

public void initialize(@NotNull
 TableDataProtocol.LocalClient 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

sendUnsubscribeRequest

public void sendUnsubscribeRequest(long requestKey,
 long requestKeyToUnsubscribe)

Specified by:

sendUnsubscribeRequest in interface TableDataProtocol.Server

sendTableLocationsRequest

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

Specified by:

sendTableLocationsRequest in interface TableDataProtocol.Server

sendTableLocationRefreshRequest

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

Specified by:

sendTableLocationRefreshRequest in interface TableDataProtocol.Server

sendColumnLocationExistenceRequest

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

Specified by:

sendColumnLocationExistenceRequest in interface TableDataProtocol.Server

sendColumnFileSizeRequest

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

Specified by:

sendColumnFileSizeRequest in interface TableDataProtocol.Server

sendColumnFileDataRequest

public void sendColumnFileDataRequest(long requestKey,
 @NotNull
 TableKey tableKey,
 @NotNull
 TableLocationKey locationKey,
 @NotNull
 CharSequence columnName,
 @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
 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