Package io.deephaven.client.impl

Class TableHandleManagerDelegate

java.lang.Object

io.deephaven.client.impl.TableHandleManagerDelegate

All Implemented Interfaces:

TableHandleManager, TableCreator<TableHandle>

Direct Known Subclasses:

SessionBase

public abstract class TableHandleManagerDelegate
extends Object
implements TableHandleManager

Nested Class Summary

Nested classes/interfaces inherited from interface io.deephaven.qst.TableCreator

TableCreator.OperationsToTable<TOPS extends TableOperations<TOPS,TABLE>,TABLE>, TableCreator.TableToOperations<TOPS extends TableOperations<TOPS,TABLE>,TABLE>

Constructor Summary

Constructors

Constructor	Description
TableHandleManagerDelegate()

Method Summary

Modifier and Type	Method	Description
protected abstract TableHandleManager	delegate()
final TableHandle	emptyTable(long size)	Equivalent to of(EmptyTable.of(size)).
final LabeledValues<TableHandle>	execute(LabeledTables tables)
final TableHandle	execute(TableSpec table)	Executes the given table, waiting for the export to complete successfully before returning.
final List<TableHandle>	execute(Iterable<TableSpec> tables)	Executes the given tables, waiting for all of the exports to complete successfully before returning.
final TableHandle	executeInputs(TableCreationLogic1Input logic, TableHandle t1)
final TableHandle	executeInputs(TableCreationLogic2Inputs logic, TableHandle t1, TableHandle t2)
final LabeledValues<TableHandle>	executeLogic(TableCreationLabeledLogic logic)
final TableHandle	executeLogic(TableCreationLogic logic)
final List<TableHandle>	executeLogic(Iterable<TableCreationLogic> logics)
final TableHandle	merge(TableHandle[] tableHandles)
final TableHandle	merge(TableHandle t1, TableHandle t2)
final TableHandle	merge(TableHandle t1, TableHandle t2, TableHandle t3)
final TableHandle	merge(TableHandle t1, TableHandle t2, TableHandle t3, TableHandle t4)
final TableHandle	merge(TableHandle t1, TableHandle t2, TableHandle t3, TableHandle t4, TableHandle t5)
final TableHandle	merge(TableHandle t1, TableHandle t2, TableHandle t3, TableHandle t4, TableHandle t5, TableHandle t6)
final TableHandle	merge(TableHandle t1, TableHandle t2, TableHandle t3, TableHandle t4, TableHandle t5, TableHandle t6, TableHandle t7)
final TableHandle	merge(TableHandle t1, TableHandle t2, TableHandle t3, TableHandle t4, TableHandle t5, TableHandle t6, TableHandle t7, TableHandle t8)
final TableHandle	merge(TableHandle t1, TableHandle t2, TableHandle t3, TableHandle t4, TableHandle t5, TableHandle t6, TableHandle t7, TableHandle t8, TableHandle t9)
final TableHandle	merge(TableHandle t1, TableHandle t2, TableHandle t3, TableHandle t4, TableHandle t5, TableHandle t6, TableHandle t7, TableHandle t8, TableHandle t9, TableHandle... remaining)
final TableHandle	merge(Iterable<TableHandle> tableHandles)	Merges the given tables.
final TableHandle	multiJoin(List<MultiJoinInput<TableHandle>> multiJoinInputs)	Creates a multi join table.
final TableHandle	newTable(Column<?>... columns)	Equivalent to of(NewTable.of(columns)).
final TableHandle	newTable(Iterable<Column<?>> columns)	Equivalent to of(NewTable.of(columns)).
final TableHandle	of(EmptyTable emptyTable)	Creates an empty table.
final TableHandle	of(InputTable inputTable)	Creates an input table.
final TableHandle	of(NewTable newTable)	Creates a new table.
final TableHandle	of(TicketTable ticketTable)	Creates a ticket table.
final TableHandle	of(TimeTable timeTable)	Creates a time table.
final TableHandle	timeTable(Duration interval)	Equivalent to of(TimeTable.of(interval)).
final TableHandle	timeTable(Duration interval, Instant startTime)	Equivalent to of(TimeTable.of(interval, startTime)).

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.deephaven.qst.TableCreator

ticket, ticket

Constructor Details

TableHandleManagerDelegate

public TableHandleManagerDelegate()

Method Details

delegate

protected abstract TableHandleManager delegate()

execute

public final TableHandle execute(TableSpec table)
                          throws TableHandle.TableHandleException,
InterruptedException

Description copied from interface: TableHandleManager

Executes the given table, waiting for the export to complete successfully before returning. If applicable, the request will build off of the existing exports.

Specified by:

execute in interface TableHandleManager

Parameters:

table - the table spec

Returns:

the table handle

Throws:

TableHandle.TableHandleException - if there was an exception on the exported table creation response or an RPC exception

InterruptedException - if the thread was interrupted while waiting

See Also:

• TableService.executeAsync(TableSpec)

execute

public final List<TableHandle> execute(Iterable<TableSpec> tables)
                                throws TableHandle.TableHandleException,
InterruptedException

Description copied from interface: TableHandleManager

Executes the given tables, waiting for all of the exports to complete successfully before returning. If applicable, the request will build off of the existing exports.

Specified by:

execute in interface TableHandleManager

Parameters:

tables - the table spec

Returns:

the table handles

Throws:

TableHandle.TableHandleException - if there was an exception in any of the exported table creation response or an RPC exception

InterruptedException - if the thread was interrupted while waiting

See Also:

• TableService.executeAsync(Iterable)

execute

public final LabeledValues<TableHandle> execute(LabeledTables tables)
                                         throws TableHandle.TableHandleException,
InterruptedException

Specified by:

execute in interface TableHandleManager

Throws:

TableHandle.TableHandleException

InterruptedException

executeLogic

public final TableHandle executeLogic(TableCreationLogic logic)
                               throws TableHandle.TableHandleException,
InterruptedException

Specified by:

executeLogic in interface TableHandleManager

Throws:

TableHandle.TableHandleException

InterruptedException

executeLogic

public final List<TableHandle> executeLogic(Iterable<TableCreationLogic> logics)
                                     throws TableHandle.TableHandleException,
InterruptedException

Specified by:

executeLogic in interface TableHandleManager

Throws:

TableHandle.TableHandleException

InterruptedException

executeLogic

public final LabeledValues<TableHandle> executeLogic(TableCreationLabeledLogic logic)
                                              throws TableHandle.TableHandleException,
InterruptedException

Specified by:

executeLogic in interface TableHandleManager

Throws:

TableHandle.TableHandleException

InterruptedException

executeInputs

public final TableHandle executeInputs(TableCreationLogic1Input logic,
 TableHandle t1)
                                throws TableHandle.TableHandleException,
InterruptedException

Specified by:

executeInputs in interface TableHandleManager

Throws:

TableHandle.TableHandleException

InterruptedException

executeInputs

public final TableHandle executeInputs(TableCreationLogic2Inputs logic,
 TableHandle t1,
 TableHandle t2)
                                throws TableHandle.TableHandleException,
InterruptedException

Specified by:

executeInputs in interface TableHandleManager

Throws:

TableHandle.TableHandleException

InterruptedException

of

public final TableHandle of(NewTable newTable)

Description copied from interface: TableCreator

Creates a new table.

Specified by:

of in interface TableCreator<TableHandle>

Parameters:

newTable - the new table specification

Returns:

the new table

of

public final TableHandle of(EmptyTable emptyTable)

Description copied from interface: TableCreator

Creates an empty table.

Specified by:

of in interface TableCreator<TableHandle>

Parameters:

emptyTable - the empty table specification

Returns:

the empty table

of

public final TableHandle of(TimeTable timeTable)

Description copied from interface: TableCreator

Creates a time table.

Specified by:

of in interface TableCreator<TableHandle>

Parameters:

timeTable - the time table specifications

Returns:

the time table

of

public final TableHandle of(TicketTable ticketTable)

Description copied from interface: TableCreator

Creates a ticket table.

Specified by:

of in interface TableCreator<TableHandle>

Parameters:

ticketTable - the ticket table

Returns:

the ticket table

of

public final TableHandle of(InputTable inputTable)

Description copied from interface: TableCreator

Creates an input table.

Specified by:

of in interface TableCreator<TableHandle>

Parameters:

inputTable - the input table specifications

Returns:

the input table

multiJoin

public final TableHandle multiJoin(List<MultiJoinInput<TableHandle>> multiJoinInputs)

Description copied from interface: TableCreator

Creates a multi join table.

Specified by:

multiJoin in interface TableCreator<TableHandle>

Parameters:

multiJoinInputs - the inputs

Returns:

the multi join table

merge

public final TableHandle merge(Iterable<TableHandle> tableHandles)

Description copied from interface: TableCreator

Merges the given tables.

Specified by:

merge in interface TableCreator<TableHandle>

Parameters:

tableHandles - the tables

Returns:

the merged results

See Also:

• MergeTable

emptyTable

public final TableHandle emptyTable(long size)

Description copied from interface: TableCreator

Equivalent to of(EmptyTable.of(size)).

Specified by:

emptyTable in interface TableCreator<TableHandle>

Parameters:

size - the size

Returns:

the empty table

See Also:

• EmptyTable.of(long)

newTable

public final TableHandle newTable(Column<?>... columns)

Description copied from interface: TableCreator

Equivalent to of(NewTable.of(columns)).

Specified by:

newTable in interface TableCreator<TableHandle>

Parameters:

columns - the columns

Returns:

the new table

See Also:

• NewTable.of(Column[])

newTable

public final TableHandle newTable(Iterable<Column<?>> columns)

Description copied from interface: TableCreator

Equivalent to of(NewTable.of(columns)).

Specified by:

newTable in interface TableCreator<TableHandle>

Parameters:

columns - the columns

Returns:

the new table

See Also:

• NewTable.of(Iterable)

timeTable

public final TableHandle timeTable(Duration interval)

Description copied from interface: TableCreator

Equivalent to of(TimeTable.of(interval)).

Specified by:

timeTable in interface TableCreator<TableHandle>

Parameters:

interval - the interval

Returns:

the time table

See Also:

• TimeTable.of(Duration)

timeTable

public final TableHandle timeTable(Duration interval,
 Instant startTime)

Description copied from interface: TableCreator

Equivalent to of(TimeTable.of(interval, startTime)).

Specified by:

timeTable in interface TableCreator<TableHandle>

Parameters:

interval - the interval

startTime - the start time

Returns:

the time table

See Also:

• TimeTable.of(Duration)

merge

public final TableHandle merge(TableHandle t1,
 TableHandle t2)

Specified by:

merge in interface TableCreator<TableHandle>

See Also:

• TableCreator.merge(Iterable)

merge

public final TableHandle merge(TableHandle t1,
 TableHandle t2,
 TableHandle t3)

Specified by:

merge in interface TableCreator<TableHandle>

See Also:

• TableCreator.merge(Iterable)

merge

public final TableHandle merge(TableHandle t1,
 TableHandle t2,
 TableHandle t3,
 TableHandle t4)

Specified by:

merge in interface TableCreator<TableHandle>

See Also:

• TableCreator.merge(Iterable)

merge

public final TableHandle merge(TableHandle t1,
 TableHandle t2,
 TableHandle t3,
 TableHandle t4,
 TableHandle t5)

Specified by:

merge in interface TableCreator<TableHandle>

See Also:

• TableCreator.merge(Iterable)

merge

public final TableHandle merge(TableHandle t1,
 TableHandle t2,
 TableHandle t3,
 TableHandle t4,
 TableHandle t5,
 TableHandle t6)

Specified by:

merge in interface TableCreator<TableHandle>

See Also:

• TableCreator.merge(Iterable)

merge

public final TableHandle merge(TableHandle t1,
 TableHandle t2,
 TableHandle t3,
 TableHandle t4,
 TableHandle t5,
 TableHandle t6,
 TableHandle t7)

Specified by:

merge in interface TableCreator<TableHandle>

See Also:

• TableCreator.merge(Iterable)

merge

public final TableHandle merge(TableHandle t1,
 TableHandle t2,
 TableHandle t3,
 TableHandle t4,
 TableHandle t5,
 TableHandle t6,
 TableHandle t7,
 TableHandle t8)

Specified by:

merge in interface TableCreator<TableHandle>

See Also:

• TableCreator.merge(Iterable)

merge

public final TableHandle merge(TableHandle t1,
 TableHandle t2,
 TableHandle t3,
 TableHandle t4,
 TableHandle t5,
 TableHandle t6,
 TableHandle t7,
 TableHandle t8,
 TableHandle t9)

Specified by:

merge in interface TableCreator<TableHandle>

See Also:

• TableCreator.merge(Iterable)

merge

public final TableHandle merge(TableHandle t1,
 TableHandle t2,
 TableHandle t3,
 TableHandle t4,
 TableHandle t5,
 TableHandle t6,
 TableHandle t7,
 TableHandle t8,
 TableHandle t9,
 TableHandle... remaining)

Specified by:

merge in interface TableCreator<TableHandle>

See Also:

• TableCreator.merge(Iterable)

merge

public final TableHandle merge(TableHandle[] tableHandles)

Specified by:

merge in interface TableCreator<TableHandle>

See Also:

• TableCreator.merge(Iterable)