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

Class TableDataProtocol.LocalServer

java.lang.Object

com.fishlib.net.impl.nio.AbstractInProcessPeer

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

All Implemented Interfaces:

com.fishlib.base.log.LogOutputAppendable, com.fishlib.net.impl.nio.AbstractPeer, TableDataProtocol.Server

Enclosing class:

TableDataProtocol

public static class TableDataProtocol.LocalServer
extends com.fishlib.net.impl.nio.AbstractInProcessPeer
implements TableDataProtocol.Server

Field Summary

Fields inherited from class com.fishlib.net.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	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 com.fishlib.net.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 com.fishlib.net.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 com.fishlib.net.impl.nio.AbstractPeer

Overrides:

shutdown in class com.fishlib.net.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