Package io.deephaven.qst

Interface TableCreator<TABLE>

Type Parameters:

TABLE - the table type

All Known Subinterfaces:

Session, TableHandleManager, TableService

All Known Implementing Classes:

SessionBase, SessionImpl, StackTraceMixInCreator, TableCreatorDelegate, TableCreatorImpl, TableCreatorImpl, TableHandleManagerDelegate

public interface TableCreator<TABLE>

Provides methods for building source tables.

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static interface	TableCreator.OperationsToTable<TOPS extends TableOperations<TOPS,TABLE>,TABLE>	Transform a table operation into a table.
static interface	TableCreator.TableToOperations<TOPS extends TableOperations<TOPS,TABLE>,TABLE>	Transform a table into a table operation.

Method Summary

Modifier and Type	Method	Description
static <TOPS extends TableOperations<TOPS, TABLE>, TABLE> TableAdapterResults<TOPS,TABLE>	create(TableCreator<TABLE> creation, TableCreator.TableToOperations<TOPS,TABLE> toOps, TableCreator.OperationsToTable<TOPS,TABLE> toTable, TableSpec table)	"Replay" the table against the given interfaces.
static <TOPS extends TableOperations<TOPS, TABLE>, TABLE> TableAdapterResults<TOPS,TABLE>	create(TableCreator<TABLE> creation, TableCreator.TableToOperations<TOPS,TABLE> toOps, TableCreator.OperationsToTable<TOPS,TABLE> toTable, Iterable<TableSpec> tables)	"Replay" the table against the given interfaces.
default TABLE	emptyTable(long size)	Equivalent to of(EmptyTable.of(size)).
TABLE	merge(Iterable<TABLE> tables)	Merges the given tables.
default TABLE	merge(TABLE[] tables)
default TABLE	merge(TABLE t1, TABLE t2)
default TABLE	merge(TABLE t1, TABLE t2, TABLE t3)
default TABLE	merge(TABLE t1, TABLE t2, TABLE t3, TABLE t4)
default TABLE	merge(TABLE t1, TABLE t2, TABLE t3, TABLE t4, TABLE t5)
default TABLE	merge(TABLE t1, TABLE t2, TABLE t3, TABLE t4, TABLE t5, TABLE t6)
default TABLE	merge(TABLE t1, TABLE t2, TABLE t3, TABLE t4, TABLE t5, TABLE t6, TABLE t7)
default TABLE	merge(TABLE t1, TABLE t2, TABLE t3, TABLE t4, TABLE t5, TABLE t6, TABLE t7, TABLE t8)
default TABLE	merge(TABLE t1, TABLE t2, TABLE t3, TABLE t4, TABLE t5, TABLE t6, TABLE t7, TABLE t8, TABLE t9)
default TABLE	merge(TABLE t1, TABLE t2, TABLE t3, TABLE t4, TABLE t5, TABLE t6, TABLE t7, TABLE t8, TABLE t9, TABLE... remaining)
TABLE	multiJoin(List<MultiJoinInput<TABLE>> inputs)	Creates a multi join table.
default TABLE	newTable(Column<?>... columns)	Equivalent to of(NewTable.of(columns)).
default TABLE	newTable(Iterable<Column<?>> columns)	Equivalent to of(NewTable.of(columns)).
TABLE	of(EmptyTable emptyTable)	Creates an empty table.
TABLE	of(InputTable inputTable)	Creates an input table.
TABLE	of(NewTable newTable)	Creates a new table.
TABLE	of(TicketTable ticketTable)	Creates a ticket table.
TABLE	of(TimeTable timeTable)	Creates a time table.
default TABLE	ticket(byte[] ticket)	Create a ticket table with the ticket bytes.
default TABLE	ticket(String ticket)	Deprecated. prefer ticket(byte[]) or other explicit methods on TicketTable
default TABLE	timeTable(Duration interval)	Equivalent to of(TimeTable.of(interval)).
default TABLE	timeTable(Duration interval, Instant startTime)	Equivalent to of(TimeTable.of(interval, startTime)).

Method Details

create

static <TOPS extends TableOperations<TOPS,
TABLE>,
TABLE>
TableAdapterResults<TOPS,TABLE> create(TableCreator<TABLE> creation,
 TableCreator.TableToOperations<TOPS,TABLE> toOps,
 TableCreator.OperationsToTable<TOPS,TABLE> toTable,
 TableSpec table)

"Replay" the table against the given interfaces.

Type Parameters:

TOPS - the table operations type

TABLE - the output table type

Parameters:

creation - the table creation

toOps - the table to operations

toTable - the operations to table

table - the table specification

Returns:

the output results

create

static <TOPS extends TableOperations<TOPS,
TABLE>,
TABLE>
TableAdapterResults<TOPS,TABLE> create(TableCreator<TABLE> creation,
 TableCreator.TableToOperations<TOPS,TABLE> toOps,
 TableCreator.OperationsToTable<TOPS,TABLE> toTable,
 Iterable<TableSpec> tables)

"Replay" the table against the given interfaces.

Type Parameters:

TOPS - the table operations type

TABLE - the output table type

Parameters:

creation - the table creation

toOps - the table to operations

toTable - the operations to table

tables - the table specifications

Returns:

the output results

of

TABLE of(NewTable newTable)

Creates a new table.

Parameters:

newTable - the new table specification

Returns:

the new table

of

TABLE of(EmptyTable emptyTable)

Creates an empty table.

Parameters:

emptyTable - the empty table specification

Returns:

the empty table

of

TABLE of(TimeTable timeTable)

Creates a time table.

Parameters:

timeTable - the time table specifications

Returns:

the time table

of

TABLE of(TicketTable ticketTable)

Creates a ticket table.

Parameters:

ticketTable - the ticket table

Returns:

the ticket table

of

TABLE of(InputTable inputTable)

Creates an input table.

Parameters:

inputTable - the input table specifications

Returns:

the input table

multiJoin

TABLE multiJoin(List<MultiJoinInput<TABLE>> inputs)

Creates a multi join table.

Parameters:

inputs - the inputs

Returns:

the multi join table

merge

TABLE merge(Iterable<TABLE> tables)

Merges the given tables.

Parameters:

tables - the tables

Returns:

the merged results

See Also:

• MergeTable

emptyTable

default TABLE emptyTable(long size)

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

Parameters:

size - the size

Returns:

the empty table

See Also:

• EmptyTable.of(long)

newTable

default TABLE newTable(Column<?>... columns)

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

Parameters:

columns - the columns

Returns:

the new table

See Also:

• NewTable.of(Column[])

newTable

default TABLE newTable(Iterable<Column<?>> columns)

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

Parameters:

columns - the columns

Returns:

the new table

See Also:

• NewTable.of(Iterable)

timeTable

default TABLE timeTable(Duration interval)

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

Parameters:

interval - the interval

Returns:

the time table

See Also:

• TimeTable.of(Duration)

timeTable

default TABLE timeTable(Duration interval,
 Instant startTime)

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

Parameters:

interval - the interval

startTime - the start time

Returns:

the time table

See Also:

• TimeTable.of(Duration)

merge

default TABLE merge(TABLE t1,
 TABLE t2)

See Also:

• merge(Iterable)

merge

default TABLE merge(TABLE t1,
 TABLE t2,
 TABLE t3)

See Also:

• merge(Iterable)

merge

default TABLE merge(TABLE t1,
 TABLE t2,
 TABLE t3,
 TABLE t4)

See Also:

• merge(Iterable)

merge

default TABLE merge(TABLE t1,
 TABLE t2,
 TABLE t3,
 TABLE t4,
 TABLE t5)

See Also:

• merge(Iterable)

merge

default TABLE merge(TABLE t1,
 TABLE t2,
 TABLE t3,
 TABLE t4,
 TABLE t5,
 TABLE t6)

See Also:

• merge(Iterable)

merge

default TABLE merge(TABLE t1,
 TABLE t2,
 TABLE t3,
 TABLE t4,
 TABLE t5,
 TABLE t6,
 TABLE t7)

See Also:

• merge(Iterable)

merge

default TABLE merge(TABLE t1,
 TABLE t2,
 TABLE t3,
 TABLE t4,
 TABLE t5,
 TABLE t6,
 TABLE t7,
 TABLE t8)

See Also:

• merge(Iterable)

merge

default TABLE merge(TABLE t1,
 TABLE t2,
 TABLE t3,
 TABLE t4,
 TABLE t5,
 TABLE t6,
 TABLE t7,
 TABLE t8,
 TABLE t9)

See Also:

• merge(Iterable)

merge

default TABLE merge(TABLE t1,
 TABLE t2,
 TABLE t3,
 TABLE t4,
 TABLE t5,
 TABLE t6,
 TABLE t7,
 TABLE t8,
 TABLE t9,
 TABLE... remaining)

See Also:

• merge(Iterable)

merge

default TABLE merge(TABLE[] tables)

See Also:

• merge(Iterable)

ticket

@Deprecated
default TABLE ticket(String ticket)

Deprecated.

prefer ticket(byte[]) or other explicit methods on TicketTable

Create a ticket table with the UTF-8 bytes from the ticket string. Equivalent to of(TicketTable.of(ticket.getBytes(StandardCharsets.UTF_8))).

Parameters:

ticket - the ticket string

Returns:

the ticket table

See Also:

• TicketTable.of(byte[])

ticket

default TABLE ticket(byte[] ticket)

Create a ticket table with the ticket bytes. Equivalent to of(TicketTable.of(ticket)).

Parameters:

ticket - the ticket

Returns:

the ticket table

See Also:

• TicketTable.of(byte[])