Package io.deephaven.extensions.barrage.util

Class PythonTableDataService

java.lang.Object

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

io.deephaven.extensions.barrage.util.PythonTableDataService

All Implemented Interfaces:

TableDataService, NamedImplementation

@ScriptApi
public class PythonTableDataService
extends AbstractTableDataService

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	PythonTableDataService.ColumnLocationImpl	ColumnLocation implementation for TableService.
static class	PythonTableDataService.TableKeyImpl	TableKey implementation for TableService.
class	PythonTableDataService.TableLocationImpl	TableLocation implementation for TableService.
static class	PythonTableDataService.TableLocationKeyImpl	TableLocationKey implementation for TableService.

Method Summary

Modifier and Type	Method	Description
static PythonTableDataService	create(@NotNull org.jpy.PyObject pyTableDataService, ChunkReader.Factory chunkReaderFactory, @Nullable BarrageOptions streamReaderOptions, int pageSize)
PartitionedTable	makePartitionedTable(@NotNull PythonTableDataService.TableKeyImpl tableKey, boolean live)	Get a Deephaven PartitionedTable for the supplied TableKey.
Table	makeTable(@NotNull PythonTableDataService.TableKeyImpl tableKey, boolean live)	Get a Deephaven Table for the supplied TableKey.
protected @NotNull TableLocationProvider	makeTableLocationProvider(@NotNull TableKey tableKey)

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, toString, wait, wait, wait

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

getImplementationName

Methods inherited from interface io.deephaven.engine.table.impl.locations.TableDataService

describe

Method Details

create

@ScriptApi
public static PythonTableDataService create(@NotNull
 @NotNull org.jpy.PyObject pyTableDataService,
 @Nullable
 ChunkReader.Factory chunkReaderFactory,
 @Nullable
 @Nullable BarrageOptions streamReaderOptions,
 int pageSize)

makeTable

@ScriptApi
public Table makeTable(@NotNull
 @NotNull PythonTableDataService.TableKeyImpl tableKey,
 boolean live)

Get a Deephaven Table for the supplied TableKey.

Parameters:

tableKey - The table key

live - Whether the table should update as new data becomes available

Returns:

The Table

makePartitionedTable

@ScriptApi
public PartitionedTable makePartitionedTable(@NotNull
 @NotNull PythonTableDataService.TableKeyImpl tableKey,
 boolean live)

Get a Deephaven PartitionedTable for the supplied TableKey.

Parameters:

tableKey - The table key

live - Whether the result should update as new data becomes available

Returns:

The PartitionedTable

makeTableLocationProvider

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

Specified by:

makeTableLocationProvider in class AbstractTableDataService