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

Class TableDataProtocol.RemoteServer

java.lang.Object

com.fishlib.io.sched.NullIOHandler

com.fishlib.net.impl.nio.AbstractRemotePeer

com.fishlib.net.impl.nio.AbstractReadaheadRemotePeer

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

All Implemented Interfaces:

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

Enclosing class:

TableDataProtocol

public static class TableDataProtocol.RemoteServer
extends com.fishlib.net.impl.nio.AbstractReadaheadRemotePeer
implements TableDataProtocol.Server

Field Summary

Fields inherited from class com.fishlib.net.impl.nio.AbstractRemotePeer

clock, peerId

Constructor Summary

Constructors

Constructor	Description
RemoteServer(int peerId, String name, com.fishlib.io.sched.IOJob job, com.fishlib.io.logger.Logger log, com.fishlib.io.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(com.fishlib.io.sched.IOJob job)
void	initialize(TableDataProtocol.ResponseHandler responseHandler)
protected void	parse(com.fishlib.net.impl.nio.WObjectReader reader)
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)
String	toString()

Methods inherited from class com.fishlib.net.impl.nio.AbstractReadaheadRemotePeer

getPeerId, handleIncoming

Methods inherited from class com.fishlib.net.impl.nio.AbstractRemotePeer

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

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

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

Constructor Details

RemoteServer

public RemoteServer(int peerId, String name, com.fishlib.io.sched.IOJob job, com.fishlib.io.logger.Logger log, com.fishlib.io.sched.PooledMessage.Pool pool, com.fishlib.base.clock.Clock clock)

Method Details

initialize

public void initialize(@NotNull TableDataProtocol.ResponseHandler responseHandler) throws IOException

Throws:

IOException

parse

protected void parse(@NotNull com.fishlib.net.impl.nio.WObjectReader reader) throws IOException

Specified by:

parse in class com.fishlib.net.impl.nio.AbstractReadaheadRemotePeer

Throws:

IOException

dispatch

protected void dispatch(boolean bufferComplete)

Specified by:

dispatch in class com.fishlib.net.impl.nio.AbstractReadaheadRemotePeer

endJob

public void endJob(@NotNull com.fishlib.io.sched.IOJob job)

Specified by:

endJob in interface com.fishlib.io.sched.IOHandler

Specified by:

endJob in class com.fishlib.net.impl.nio.AbstractRemotePeer

sendUnsubscribeRequest

public void sendUnsubscribeRequest(long requestKey, long requestKeyToUnsubscribe) throws IOException

Specified by:

sendUnsubscribeRequest in interface TableDataProtocol.Server

Throws:

IOException

sendTableLocationsRequest

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

Specified by:

sendTableLocationsRequest in interface TableDataProtocol.Server

Throws:

IOException

sendTableLocationRefreshRequest

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

Specified by:

sendTableLocationRefreshRequest in interface TableDataProtocol.Server

Throws:

IOException

sendColumnLocationExistenceRequest

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

Specified by:

sendColumnLocationExistenceRequest in interface TableDataProtocol.Server

Throws:

IOException

sendColumnFileSizeRequest

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

Specified by:

sendColumnFileSizeRequest in interface TableDataProtocol.Server

Throws:

IOException

sendColumnFileDataRequest

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

Specified by:

sendColumnFileDataRequest in interface TableDataProtocol.Server

Throws:

IOException

toString

public String toString()

Overrides:

toString in class com.fishlib.net.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 com.fishlib.net.impl.nio.AbstractRemotePeer