Package com.illumon.iris.db.util

Class InteractiveConsoleQuerySession

java.lang.Object
com.illumon.iris.db.util.InteractiveConsoleQuerySession
All Implemented Interfaces:
ScriptSession
public class InteractiveConsoleQuerySession extends Object implements ScriptSession

  • Field Details

    • INTERACTIVE_CONSOLE_QUERY_ATTACHMENT_RESULTS

      public static String INTERACTIVE_CONSOLE_QUERY_ATTACHMENT_RESULTS

    • HEARTBEAT_INTERVAL

      public static long HEARTBEAT_INTERVAL

    • HEARTBEAT_POLL_INTERVAL

      public static long HEARTBEAT_POLL_INTERVAL

    • TERMINATION_DELAY

      public static long TERMINATION_DELAY

  • Constructor Details

    • InteractiveConsoleQuerySession

      public InteractiveConsoleQuerySession(ScriptSession wrappedSession, boolean isPrimarySession, boolean isViewOnly)

  • Method Details

    • getVariable

      public Object getVariable(String name) throws QueryScope.MissingVariableException
      Description copied from interface: ScriptSession
      Retrieve a variable from the script session's bindings.
      Specified by:
      getVariable in interface ScriptSession
      Parameters:
      name - the variable to retrieve
      Returns:
      the variable
      Throws:
      QueryScope.MissingVariableException - if the variable does not exist

    • getVariable

      public <T> T getVariable(String name, T defaultValue)
      Description copied from interface: ScriptSession
      Retrieve a variable from the script session's bindings. If the variable is not present, return defaultValue. If the variable is present, but is not of type (T), a ClassCastException may result.
      Specified by:
      getVariable in interface ScriptSession
      Type Parameters:
      T - the type of the variable
      Parameters:
      name - the variable to retrieve
      defaultValue - the value to use when no value is present in the session's scope
      Returns:
      the value of the variable, or defaultValue if not present

    • evaluate

      public void evaluate(String command)
      Description copied from interface: ScriptSession
      Evaluates command in the context of the current ScriptSession.
      Specified by:
      evaluate in interface ScriptSession
      Parameters:
      command - the command to evaluate

    • evaluate

      public void evaluate(String command, @Nullable String scriptName)
      Description copied from interface: ScriptSession
      Evaluates command in the context of the current ScriptSession.
      Specified by:
      evaluate in interface ScriptSession
      Parameters:
      command - the command to evaluate
      scriptName - an optional script name, which may be ignored by the implementation, or used improve error messages or for other internal purposes

    • getVariables

      public Map<String,Object> getVariables()
      Description copied from interface: ScriptSession
      Retrieves all of the variables present in the session's scope (e.g., Groovy binding, Python globals()).
      Specified by:
      getVariables in interface ScriptSession
      Returns:
      an unmodifiable map with variable names as the keys, and the Objects as the result

    • getVariableNames

      public Set<String> getVariableNames()
      Description copied from interface: ScriptSession
      Retrieves all of the variable names present in the session's scope
      Specified by:
      getVariableNames in interface ScriptSession
      Returns:
      an unmodifiable set of variable names

    • hasVariableName

      public boolean hasVariableName(String name)
      Description copied from interface: ScriptSession
      Check if the scope has the given variable name
      Specified by:
      hasVariableName in interface ScriptSession
      Parameters:
      name - the variable name
      Returns:
      True iff the scope has the given variable name

    • setVariable

      public void setVariable(String name, Object value)
      Description copied from interface: ScriptSession
      Inserts a value into the script's scope.
      Specified by:
      setVariable in interface ScriptSession
      Parameters:
      name - the variable name to set
      value - the new value of the variable

    • scriptType

      public String scriptType()
      Specified by:
      scriptType in interface ScriptSession
      Returns:
      a textual description of this script session's language for use in messages.

    • onPersistentQueryInitializationBegin

      public void onPersistentQueryInitializationBegin(Supplier<ScriptPathLoader> pathLoader, ScriptPathLoaderState scriptLoaderState)
      Description copied from interface: ScriptSession
      Called before PersistentQuery initialization, should setup sourcing from the controller (as required).
      Specified by:
      onPersistentQueryInitializationBegin in interface ScriptSession

    • onPersistentQueryInitializationEnd

      public void onPersistentQueryInitializationEnd()
      Description copied from interface: ScriptSession
      Called after PersistentQuery initialization.
      Specified by:
      onPersistentQueryInitializationEnd in interface ScriptSession

    • setScriptPathLoader

      public void setScriptPathLoader(Supplier<ScriptPathLoader> scriptPathLoader, boolean caching)
      Description copied from interface: ScriptSession
      Sets the scriptPathLoader that is in use for this session.
      Specified by:
      setScriptPathLoader in interface ScriptSession
      Parameters:
      scriptPathLoader - a supplier of a script path loader
      caching - whether the source operation should cache results

    • clearScriptPathLoader

      public void clearScriptPathLoader()
      Description copied from interface: ScriptSession
      Removes the currently configured script path loader from this script.
      Specified by:
      clearScriptPathLoader in interface ScriptSession

    • setUseOriginalScriptLoaderState

      public boolean setUseOriginalScriptLoaderState(boolean useOriginal)
      Description copied from interface: ScriptSession
      Informs the session whether or not we should be using the original ScriptLoaderState for source commands.
      Specified by:
      setUseOriginalScriptLoaderState in interface ScriptSession
      Parameters:
      useOriginal - whether to use the script loader state at persistent query initialization

    • isInteractiveConsoleSession

      public boolean isInteractiveConsoleSession()
      Description copied from interface: ScriptSession
      Identifies if the session is an interactive/shared console which allows multiple clients to share a single query-scope
      Specified by:
      isInteractiveConsoleSession in interface ScriptSession
      Returns:
      true if the session is an interactive console

    • getWrappedSession

      public ScriptSession getWrappedSession()
      Specified by:
      getWrappedSession in interface ScriptSession

    • heartbeat

      public static boolean heartbeat(ExportedObjectClient client)

    • activeClientCount

      public static int activeClientCount(long terminationDelay)

    • removeActiveClient

      public static int removeActiveClient(ExportedObjectClient client)