Striim Cloud 4.1.2 documentation

At the bottom of the Console page, enter a command, then click Execute.

The command's output will appear above.

If a command requires a file as an argument, upload it as described in Manage Striim - Files. Specify the path as UploadedFiles/<user name>/<file name>, for example, UploadedFiles/MyUserName/MyApp.tql.

In this release, SELECT commands (ad-hoc queries) are not supported in the web console.

If Striim is installed in /opt, the command to run the console is:

/opt/Striim/bin/console.sh -c <cluster name>

In Windows, if Striim is installed in c:\striim, the command to run the console is:

\striim\bin\console -c <cluster name>

The following switches may be used:

-c <cluster name>: the name of the cluster to connect to (if omitted, will default to the current user name)

-f <path><file name>.tql: a TQL file containing commands to run when console starts (if not specified from root, path is relative to the Striim program directory)

-H false: if HTTPS has been disabled, use this to connect to Striim using HTTP

-i <IP address>: if the system has multiple IP addresses, specify the one for the console to use

-p <password>: the password to use to log in (if omitted, you will be prompted after the console connects)

-S <IP address>: the IP address of the Striim server (the value of ServerNodeAddress in startUp.properties; required if HTTP has been disabled)

-t <port>: specify the HTTP port if not 9080

-T <port>: specify the HTTPS port if not 9081

-u <user name>: the user to log in as (if omitted, you will be prompted after the console connects)

The following commands are intended primarily for use at the command line rather than in .tql application files. DDL and component reference and ad-hoc queries may also be entered at the command line.

@<path>/<file name>.tql [passphrase=<passphrase>];

Run the commands in the specified TQL file (typically all the commands required to create an application). If not specified from root, path is relative to the Striim program directory. If the TQL was exported with a passphrase (see Exporting applications and dashboards), specify it with the passphrase option. Note that if the file contains DDL defining an application, the name will be defined by the CREATE APPLICATION statement, not the TQL file name.Exporting applications and dashboards

Deploys an application in the Created state. See Managing deployment groups.

DESCRIBE <namespace>.<object name>;

Returns all properties of the specified component, application, or flow. DESCRIBE CLUSTER; returns the cluster name, information about the metadata repository, and license details. 

EXPORT APPLICATION { ALL | <namespace>.<application name>,... } [TO "<path>" [passphrase="<passphrase>"]];

Exports applications as TQL files. Specify either ALL to export all applications or a list of applications separated by commas. See Encrypted passwords for discussion of passphrases. If you do not specify a path, files will be saved to the striim directory.

Except for applications in the current namespace when the command is run, component names in the exported TQL will include their namespaces. Remove those before importing the TQL into a different namespace.

EXPORT <stream name>;

See Reading a Kafka stream with an external Kafka consumer.

HISTORY;

Lists all commands previously entered in the current console session.

LIST { <component type> };

Returns a list of all objects of the specified type.

LIST LIBRARIES;

Lists currently loaded open processors (see Loading and unloading open processors).

See Loading standalone sources, caches, and WActionStores, or Creating an open processor component.

See Using the MON command.

PREVIEW <namespace>.<CQ name> { INPUT | OUTPUT | INPUTOUTPUT } [LIMIT <maximum number of events>]

Returns current input and/or output events for the specified CQ. If you do not specify value for LIMIT, the command will return a maximum of 1000 input events and/or 1000 output events.

Each event in the command's output includes:

For example, the command PREVIEW Samples.PosData5Minutes inputoutput limit 1; will return something similar to:

Processing - preview samples.CsvToPosData inputoutput limit 1
Source:"Samples.CsvStream",IO:"I",Action:"added",Server:"S192_168_7_91",
Data:"[[COMPANY 366761, 9XGDirhiN2UPnJ9w5GqmISM2QXe1Coav3Fq, 0558659360821268472, 6, 
20130312174714, 0615, USD, 8.42, 8641415475152637, 61064, Polo], 
{FileOffset=0, RecordEnd=49798966, RecordOffset=49798836, FileName=posdata.csv, 
RecordStatus=VALID_RECORD}]"
Source:"Samples.CsvToPosData",IO:"O",Action:"added",Server:"S192_168_7_91",
Data:"[9XGDirhiN2UPnJ9w5GqmISM2QXe1Coav3Fq, 2013-03-12T17:47:14.000-07:00, 17, 8.42, 61064];"

QUIESCE <namespace>.<application name> [CASCADE];

If you specify the CASCADE option, any downstream applications that consume events from the specified application via persisted streams will also be quiesced.

The primary uses for QUIESCE are to flush out remaining data at the end of a data set and to create a recovery checkpoint with no data in process prior to using ALTER on an application with recovery enabled (see ALTER and RECOMPILE).

Due to long-running open transactions, OracleReader may be unable to pause within 30 seconds, in which case the application and all its sources will resume as if the QUIESCE command had not been issued.

To support QUIESCE with OracleReader, see Creating the QUIESCEMARKER table for Oracle Reader.

Seee Using the REPORT START / STOP command.

When an application is in the TERMINATED state and the condition that caused it to terminate has been corrected, RESUME <application name>; will attempt to resume operation from the point where the application terminated. Data may be lost if recovery was not enabled (see Recovering applications).

Queries a WActionStore. See Browsing data with ad-hoc queries.

Show current stream output

SHOW <namespace>.<stream name>;

Returns the output of a stream. Press Ctrl-D to end.

Show open transactions in Oracle Reader

With OracleReader, SHOW can also be used for Viewing open transactions.

Show checkpoint history

See Recovering applications.Recovering applications

Show OJet status and memory usage

See Runtime considerations when using OJet.

START <namespace>.<application name>;

Starts the specified application.

STATUS <server name>;

Lists all applications deployed or running on the specified server.

STATUS <namespace>.<application name>;

Returns the status of the specified application. See Application states.

STOP <namespace>.<application name>;

Stops a running application and, if recovery is enabled, writes recovery checkpoints. If recovery is enabled and  the application was not dropped after it was stopped, recoverable sources will restart from the point immediately after the last written events (see Recovering applications). If recovery is not enabled, any data currently being processed will be lost.

The Stop command is also available when an application is in the Starting state. This can be useful when an application is stuck in the Starting state and you want to stop and debug it rather than waiting for it to time out and revert to the Deployed state.

Undeploys a deployed application. See Managing deployment groups.

The Undeploy command is also available when an application is in the Deploying state. This can be useful when an application is stuck in the Deploying state and you want to stop and debug it rather than waiting for it to time out and revert to the Created state.

See Loading standalone sources, caches, and WActionStores, or Creating an open processor component.

USAGE [<namespace>.<application name>];

Lists sources and how much total data each has acquired. If you do not specify an application name, USAGE; lists all sources for all applications.