Package com.illumon.iris.controller

Class PersistentQuery

java.lang.Object

com.illumon.iris.controller.PersistentQuery

public class PersistentQuery
extends Object

A PersistentQuery represents a single run of a Deephaven persistent query. It connects to a dispatcher, starts the query, and manages its state.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	PersistentQuery.UnknownSessionException

Field Summary

Fields

Modifier and Type	Field	Description
static String	PERSISTENT_QUERY_CONFIG_VARIABLE_NAME
static String	PERSISTENT_QUERY_NAME_VARIABLE_NAME
static String	PERSISTENT_QUERY_OWNER_VARIABLE_NAME
static String	PERSISTENT_QUERY_SERIAL_NUMBER_VARIABLE_NAME

Method Summary

Modifier and Type	Method	Description
static int	addSession(ScriptSession newSession, ExportedObjectClient client)	Add a new ScriptSession to this PQ for the specified client.
static void	checkPrimaryScriptSession()
static ScriptSession	createSession(PersistentQueryConfiguration config, Map<String,Object> variableMap, Function<Constructor<? extends ScriptSession>,ScriptSession> constructionWrapper)
static void	disableSource(IrisDbGroovySession groovySession)
static void	extractTableAndWidgetMetadata(Map<String,Object> currentScope, Map<String,String[]> localTableGroups, Map<String,ExportedObjectInfo> localObjects)
static QueryScope	getQueryScope(int sessionKey)	Get the QueryScope for the specified session key.
static ScriptSession	getScriptSession(int sessionKey)
static PersistentQueryState	getSessionState(PersistentQueryConfiguration config, ScriptSession session, TypeSpecificQueryState typeSpecificState)
static PersistentQueryState	getStateWithoutSession(PersistentQueryConfiguration config, TypeSpecificQueryState typeSpecificState)
QueryProcessorConnection	getWorker()
static boolean	removeSession(int id)	Remove the specified session from this query
static void	setPrimaryScriptSession(ScriptSession session)
static void	setVisibility(PersistentQueryConfiguration config, RemoteQueryProcessor remoteQueryProcessor)

Methods inherited from class java.lang.Object

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

Field Details

PERSISTENT_QUERY_CONFIG_VARIABLE_NAME

public static final String PERSISTENT_QUERY_CONFIG_VARIABLE_NAME

See Also:

Constant Field Values

PERSISTENT_QUERY_SERIAL_NUMBER_VARIABLE_NAME

public static final String PERSISTENT_QUERY_SERIAL_NUMBER_VARIABLE_NAME

See Also:

Constant Field Values

PERSISTENT_QUERY_OWNER_VARIABLE_NAME

public static final String PERSISTENT_QUERY_OWNER_VARIABLE_NAME

See Also:

Constant Field Values

PERSISTENT_QUERY_NAME_VARIABLE_NAME

public static final String PERSISTENT_QUERY_NAME_VARIABLE_NAME

See Also:

Constant Field Values

Method Details

getWorker

public QueryProcessorConnection getWorker()

checkPrimaryScriptSession

public static void checkPrimaryScriptSession()

createSession

public static ScriptSession createSession(PersistentQueryConfiguration config, @NotNull Map<String,Object> variableMap, Function<Constructor<? extends ScriptSession>,ScriptSession> constructionWrapper)

setPrimaryScriptSession

public static void setPrimaryScriptSession(ScriptSession session)

setVisibility

public static void setVisibility(PersistentQueryConfiguration config, RemoteQueryProcessor remoteQueryProcessor)

getSessionState

public static PersistentQueryState getSessionState(PersistentQueryConfiguration config, ScriptSession session, @Nullable TypeSpecificQueryState typeSpecificState)

getStateWithoutSession

public static PersistentQueryState getStateWithoutSession(PersistentQueryConfiguration config, @Nullable TypeSpecificQueryState typeSpecificState)

extractTableAndWidgetMetadata

public static void extractTableAndWidgetMetadata(Map<String,Object> currentScope, Map<String,String[]> localTableGroups, Map<String,ExportedObjectInfo> localObjects)

disableSource

public static void disableSource(IrisDbGroovySession groovySession)

getScriptSession

public static ScriptSession getScriptSession(int sessionKey)

getQueryScope

public static QueryScope getQueryScope(int sessionKey)

Get the QueryScope for the specified session key.

Parameters:

sessionKey - the identifying session key

Returns:

the QueryScope

Throws:

PersistentQuery.UnknownSessionException - if the session does not exist.

addSession

public static int addSession(@NotNull ScriptSession newSession, @NotNull ExportedObjectClient client)

Add a new ScriptSession to this PQ for the specified client.

Parameters:

newSession - the session

client - the client associated

Returns:

the unique ID of this new session.

removeSession

public static boolean removeSession(int id)

Remove the specified session from this query

Parameters:

id - the ID of the session.

Returns:

true if the session was removed