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
void	close()	Close and release the underlying session and channel for this session.
io.deephaven.client.impl.FlightSession	getFlightSession()
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, 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

getFlightSession

public io.deephaven.client.impl.FlightSession getFlightSession()

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

close

public void close()
           throws IOException

Description copied from class: DndSession

Close and release the underlying session and channel for this session. If requested, also delete the Persistent Query

Overrides:

close in class DndSession

Throws:

IOException