Package io.deephaven.enterprise.dnd.client

Class DndSessionFlight

java.lang.Object

io.deephaven.enterprise.dnd.client.DndSession

io.deephaven.enterprise.dnd.client.DndSessionFlight

public class DndSessionFlight
extends DndSession

A session on a Persistent Query used to access tables using Arrow Flight

Field Summary

Fields inherited from class io.deephaven.enterprise.dnd.client.DndSession

allocator, channel, sessionImpl

Method Summary

Modifier and Type	Method	Description
org.apache.arrow.flight.FlightStream	streamOf(io.deephaven.qst.table.TableSpec table)	Fetch a FlightStream of the specified TableSpec

Methods inherited from class io.deephaven.enterprise.dnd.client.DndSession

allocator, catalogTable, channel, close, executeCode, getInfo, historicalTable, liveTable, scopeTable, session

Methods inherited from class java.lang.Object

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

Method Details

streamOf

public org.apache.arrow.flight.FlightStream streamOf(@NotNull
 io.deephaven.qst.table.TableSpec table)
                                              throws io.deephaven.client.impl.TableHandle.TableHandleException,
InterruptedException

Fetch a FlightStream of the specified TableSpec

Parameters:

table - the table to fetch.

Returns:

a new FlightStream

Throws:

io.deephaven.client.impl.TableHandle.TableHandleException

InterruptedException