Package io.deephaven.enterprise.tabledataservice

Class RemoteTableDataService

java.lang.Object

io.deephaven.engine.table.impl.locations.impl.AbstractTableDataService

io.deephaven.enterprise.tabledataservice.RemoteTableDataService

All Implemented Interfaces:

TableDataService, NamedImplementation

public class RemoteTableDataService
extends AbstractTableDataService

A TableDataService implementation that uses Enterprise's TableDataProtocol to locate tables.

Constructor Summary

Constructors

Constructor	Description
RemoteTableDataService(@NotNull io.deephaven.shadow.enterprise.com.illumon.iris.db.schema.SchemaService schemaService, @NotNull io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.locations.protocol.TableDataProtocolDriver protocolDriver, @NotNull String name)	Construct a new remote table data service, ready to be connected.

Method Summary

Modifier and Type	Method	Description
void	connect(@NotNull InetSocketAddress address)	Connect to a remote server.
void	connect(io.deephaven.shadow.enterprise.com.fishlib.base.Function.Nullary<SocketAddress> addressFunction)	Connect to a remote server by address function, allowing fallback to different server addresses.
String	describe()
protected @NotNull TableLocationProvider	makeTableLocationProvider(@NotNull TableKey tableKey)
String	toString()

Methods inherited from class io.deephaven.engine.table.impl.locations.impl.AbstractTableDataService

getName, getRawTableLocationProvider, getTableLocationProvider, reset, reset

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.deephaven.util.type.NamedImplementation

getImplementationName

Constructor Details

RemoteTableDataService

public RemoteTableDataService(@NotNull
 @NotNull io.deephaven.shadow.enterprise.com.illumon.iris.db.schema.SchemaService schemaService,
 @NotNull
 @NotNull io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.locations.protocol.TableDataProtocolDriver protocolDriver,
 @NotNull
 @NotNull String name)

Construct a new remote table data service, ready to be connected.

Parameters:

schemaService - The SchemaService to use for locating TableDefinitions

protocolDriver - The table data protocol driver.

name - Remote service name

Method Details

connect

public void connect(@NotNull
 @NotNull InetSocketAddress address)
             throws IOException

Connect to a remote server.

Parameters:

address - The host/port to connect to

Throws:

IOException

connect

public void connect(@NotNull
 io.deephaven.shadow.enterprise.com.fishlib.base.Function.Nullary<SocketAddress> addressFunction)
             throws IOException

Connect to a remote server by address function, allowing fallback to different server addresses.

Parameters:

addressFunction - The address function to determine each connection attempt's host and port

Throws:

IOException

makeTableLocationProvider

@NotNull
protected @NotNull TableLocationProvider makeTableLocationProvider(@NotNull
 @NotNull TableKey tableKey)

Specified by:

makeTableLocationProvider in class AbstractTableDataService

toString

public String toString()

Overrides:

toString in class Object

describe

public String describe()