Package com.illumon.iris.db.tables.remote

Class ExportedTableHandleManager

java.lang.Object

com.illumon.iris.db.tables.remote.ExportedTableHandleManager

All Implemented Interfaces:

com.fishlib.base.log.LogOutputAppendable

public class ExportedTableHandleManager
extends Object
implements com.fishlib.base.log.LogOutputAppendable

Exports tables to a RemoteTableHandleManager, for access via a proxy. Used for a single client to a RemoteQueryProcessor.

Constructor Summary

Constructors

Constructor	Description
ExportedTableHandleManager(ExportedObjectClient client, com.fishlib.io.logger.Logger log)

Method Summary

Modifier and Type	Method	Description
boolean	addPreemptiveSubscription(int handleId, BitSet columnsToSubscribe, boolean isViewport)
com.fishlib.base.log.LogOutput	append(com.fishlib.base.log.LogOutput logOutput)
Table	getTableForHandle(int handleId)	Gets the table for the given handle id.
Object[]	invokeMethod(int handleId, String methodName, Class[] argumentTypes, Object[] args)
Inflatable<Table>	makeHandleAndGetDescriptor(Table table)
Inflatable<Table>	makeHandleAndGetDescriptor(Table table, boolean preSubscribed, boolean preSubscribedViewport)
void	onDisconnection()
void	releaseHandle(int handleId)
boolean	removePreemptiveSubscription(int handleId)
String	toString()
boolean	updatePreemptiveSubscription(int handleId, BitSet columnsToSubscribe)
boolean	updateViewPort(int handleId, Index viewPort)
boolean	updateViewportAndColumns(int handleId, Index viewPort, BitSet columnsToSubscribe)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details

ExportedTableHandleManager

public ExportedTableHandleManager(@NotNull ExportedObjectClient client, @NotNull com.fishlib.io.logger.Logger log)

Parameters:

client - The client state

log - The log

Method Details

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

makeHandleAndGetDescriptor

public Inflatable<Table> makeHandleAndGetDescriptor(@NotNull Table table)

makeHandleAndGetDescriptor

public Inflatable<Table> makeHandleAndGetDescriptor(@NotNull Table table, boolean preSubscribed, boolean preSubscribedViewport)

releaseHandle

public void releaseHandle(int handleId)

getTableForHandle

@NotNull public Table getTableForHandle(int handleId)

Gets the table for the given handle id. Throws IllegalStateException if the handle does not exist.

Parameters:

handleId - the integer ID for the handle

Returns:

the table associated with the handleId

Throws:

IllegalStateException - if there is no such handle

onDisconnection

public void onDisconnection()

invokeMethod

public Object[] invokeMethod(int handleId, String methodName, Class[] argumentTypes, Object[] args)

addPreemptiveSubscription

public boolean addPreemptiveSubscription(int handleId, @NotNull BitSet columnsToSubscribe, boolean isViewport)

removePreemptiveSubscription

public boolean removePreemptiveSubscription(int handleId)

updatePreemptiveSubscription

public boolean updatePreemptiveSubscription(int handleId, @NotNull BitSet columnsToSubscribe)

updateViewPort

public boolean updateViewPort(int handleId, @NotNull Index viewPort)

updateViewportAndColumns

public boolean updateViewportAndColumns(int handleId, @NotNull Index viewPort, @NotNull BitSet columnsToSubscribe)