Package io.deephaven.kv.schema

Class SchemaContext

java.lang.Object

io.deephaven.kv.KeyPathContextBase

io.deephaven.kv.meta.AtomicDirectoryContext

io.deephaven.kv.schema.SchemaContext

All Implemented Interfaces:

Context, KeyPathContext

@Reusable
public class SchemaContext
extends AtomicDirectoryContext

A dynamic KeyPath model for the schema store (starting key path /main/config/schema). Each (non-metadata) following path part represents a SchemaNamespaceContext.

Models the data in Schemas

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	SchemaContext.GetSchemaNamespaceNames
static interface	SchemaContext.GetSchemaNamespaces
class	SchemaContext.NamespaceNames
class	SchemaContext.Namespaces
static interface	SchemaContext.SchemasStateListener	A stateful watch listener interface for Schemas.

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
SchemaContext.NamespaceNames	asNamespaceNames()
SchemaContext.Namespaces	asNamespaces()
SchemaNamespaceContext	getNamespaceContext(String namespace)
SchemaTableContext	getSchemaTableContextFromXml(byte[] value)
SchemaStateAdapter	watch(KVClient kvClient, WatchClient watchClient, WatchClient.StateListener<SchemaStateAdapter.State> stateListener, int limit)	Start a watch on the schema context, with a limit on the number of entries to retrieve at one time.

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

getNamespaceContext

public SchemaNamespaceContext getNamespaceContext(String namespace)

asNamespaces

public SchemaContext.Namespaces asNamespaces()

asNamespaceNames

public SchemaContext.NamespaceNames asNamespaceNames()

getSchemaTableContextFromXml

public SchemaTableContext getSchemaTableContextFromXml(byte[] value)
                                                throws XMLStreamException

Throws:

XMLStreamException

watch

public SchemaStateAdapter watch(KVClient kvClient,
 WatchClient watchClient,
 WatchClient.StateListener<SchemaStateAdapter.State> stateListener,
 int limit)

Start a watch on the schema context, with a limit on the number of entries to retrieve at one time.

Parameters:

kvClient - "the KVClient"

watchClient - "the WatchClient"

stateListener - the listener for SchemaStateAdapter.State updates

limit - responses with more than this many keys will be broken into multiple requests.

Returns:

a SchemaStateAdapter, which can produce a future for the watch and recover from errors