Package io.deephaven.kv.pq

Class PersistentQueriesContext

java.lang.Object

io.deephaven.kv.KeyPathContextBase

io.deephaven.kv.meta.AtomicDirectoryContext

io.deephaven.kv.files.FilesContext

io.deephaven.kv.pq.PersistentQueriesContext

All Implemented Interfaces:

Context, KeyPathContext

@Reusable
public class PersistentQueriesContext
extends FilesContext

A dynamic KeyPath model for persistent queries. Each (non-metadata) path represents a PersistentQueriesContext.

Models the data in PersistentQueries

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	PersistentQueriesContext.GetPQs
static interface	PersistentQueriesContext.PersistentQueriesListener	A stateful watch listener interface for PersistentQueries.
class	PersistentQueriesContext.PQs

Nested classes/interfaces inherited from class io.deephaven.kv.files.FilesContext

FilesContext.FileIdentifiers, FilesContext.Files, FilesContext.FilesListener, FilesContext.GetFileIdentifiersRequest, FilesContext.GetFilesRequest

Nested classes/interfaces inherited from class io.deephaven.kv.meta.AtomicDirectoryContext

AtomicDirectoryContext.AtomicUpdateWrt, AtomicDirectoryContext.MetaDescription

Field Summary

Fields inherited from class io.deephaven.kv.meta.AtomicDirectoryContext

META, META_PART, parent

Fields inherited from class io.deephaven.kv.KeyPathContextBase

context, description

Method Summary

Modifier and Type	Method	Description
PersistentQueriesContext.PQs	asPQs()
DataContext	getDataContext()
PersistentQueryContext	getPQContext(long serial)
CompletableFuture<WatchClient.Watch>	watch(KVClient kvClient, WatchClient watchClient, PersistentQueriesContext.PersistentQueriesListener listener)

Methods inherited from class io.deephaven.kv.files.FilesContext

asFileIdentifiers, asFiles, atomic, atomic, atomicDelete, entry, getAtomicChanges, getFileContext, watch

Methods inherited from class io.deephaven.kv.meta.AtomicDirectoryContext

asDelete, atomic, atomicDelete, atomicDeleteChildren, expectNewWrtThis, expectUpdateWrtThis, getMetaInfoContext, getMetaInfoContext, getReadPermissions, getReadWritePaths, getReadWritePermissions, isLowestLevelAtomicDirectory, isMetaPart, isNotMeta, parseDirectoryListing, parseDirectoryListingStream, parseDirectoryListingStreamToSubset, watch, watch, watch, wrtAtomicConditionIsTrueHandleUs

Methods inherited from class io.deephaven.kv.KeyPathContextBase

equals, getDescription, getPath, hashCode

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.deephaven.kv.KeyPathContext

resolve

Method Details

getDataContext

public DataContext getDataContext()

getPQContext

public PersistentQueryContext getPQContext(long serial)

asPQs

public PersistentQueriesContext.PQs asPQs()

watch

public CompletableFuture<WatchClient.Watch> watch(KVClient kvClient,
 WatchClient watchClient,
 PersistentQueriesContext.PersistentQueriesListener listener)