com.streambase.sb.client

Class StreamBaseAdminClient

java.lang.Object

com.streambase.sb.client.StreamBaseAdminClient

All Implemented Interfaces:

java.lang.AutoCloseable

public class StreamBaseAdminClient
extends java.lang.Object

This class is used to send administrative commands to the StreamBase Server

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	StreamBaseAdminClient.ListConnectionArgument Valid arguments for the listConnection command

Constructor Summary

Constructors

Constructor and Description
StreamBaseAdminClient() Create a StreamBaseAdminClient.
StreamBaseAdminClient(java.util.List<StreamBaseURI> uris) Create a StreamBaseAdminClient.
StreamBaseAdminClient(java.util.List<StreamBaseURI> uris, ClientSettings settings) Create a StreamBaseAdminClient.
StreamBaseAdminClient(StreamBaseURI uri) Create a StreamBaseAdminClient, connecting to the server at the provided URI.
StreamBaseAdminClient(java.lang.String uri) Create a StreamBaseAdminClient.

Method Summary

Modifier and Type	Method and Description
java.lang.String[]	addContainer(java.lang.String containerName, byte[] application, java.util.List<java.lang.String> options) Add the given application to the given container in the StreamBase server
java.lang.String[]	addContainer(java.lang.String containerName, java.io.File application, java.util.List<java.lang.String> options) Add the given application to the given container in the StreamBase server
java.lang.String[]	addContainer(java.lang.String containerName, java.lang.String applicationText, java.util.List<java.lang.String> options) Add the given application to the given container in the StreamBase server
java.lang.String[]	addDeploy(byte[] deployText, java.lang.String... args) Add the given deployment file to the server given the byte content of the file.
java.lang.String[]	addDeploy(java.io.File deployFile, java.lang.String... options) Adds applications and containers defined in the given deployment or archive file to the StreamBase server.
java.lang.String[]	addDeploy(java.lang.String deployText, java.lang.String... args) Add the given deployment file to the server given the text of the file
java.lang.String	clearEvalCache(java.lang.String containerName)
void	close() Close/shutdown the connection to the StreamBase server.
void	drain() Drain a StreamBase Server Has no effect if the server is not running
void	drain(java.lang.String containerName) Drain a container within a StreamBase Server Has no effect if the server is not running
void	fastForwardTime(java.lang.String msecs)
java.lang.String	getEvalCacheContent(java.lang.String containerName)
Constants.LeadershipStatus	getLeadershipStatus() Get the leadership status of the server.
java.lang.String	getMapperCacheContent(java.lang.String containerName)
java.lang.String[]	getOperatorProperties(java.lang.String operatorName) For the given Operator, return its set of properties and their values.
java.lang.String	getOperatorProperty(java.lang.String operatorName, java.lang.String propertyName) Return the value of the given property on the given Operator.
ClientSettings	getSettings() Return the settings for this client
java.lang.String	getTargetTime()
StreamBaseURI	getURI() Return the URI used by this Client.
java.util.List<StreamBaseURI>	getURIs() get all of the URI's for this client
protected boolean	haModeOn() is HA mode on
java.lang.String[]	killAllConnections() Kill all of the connections on the server
java.lang.String[]	killConnection(byte[] connectionId) Kill the connection with the given connectionId
java.lang.String[]	listConnections(StreamBaseAdminClient.ListConnectionArgument... args) Return an array of client connections
java.lang.String[]	listEntities(java.lang.String entityType, int flags) Return an array of entity names for the given entity type
java.lang.String[]	manageJdbcConnections(java.util.List<java.lang.String> args) Manage JDBC connections: count [name]Count the open JDBC connections to the named data source (or all data sources if ommitted) close [name]Close any open JDBC connections to the named data source (or all data sources if ommitted)
java.lang.String[]	modifyContainer(java.lang.String containerName, java.util.List<java.lang.String> options) Modifies the given container.
java.lang.String[]	operatorStatus(java.lang.String containerName) Return the status of all the operators in the specified container
java.lang.String[]	removeContainer(java.lang.String containerName, java.lang.String... args) Remove the given container in the StreamBase server
java.lang.String[]	restartContainer(java.lang.String containerName)
void	restartOperators(java.util.List<java.lang.String> operatorNames) Restart the given Operators on the StreamBase server.
void	resume(java.lang.String containerName) Resume a container in a StreamBase server
void	resumeOperators(java.util.List<java.lang.String> operatorNames) Resume the given Operators on the StreamBase server
void	setLeadershipStatus(Constants.LeadershipStatus leadershipStatus) Set the leadership status of the server.
void	setOperatorProperty(java.lang.String operatorName, java.lang.String propertyName, java.lang.String value) On the given Operator, set the given property to the given value.
void	setRuntimeParam(java.lang.String paramName, java.lang.String paramValue, java.lang.String operator) Set a runtime parameter on one, or all, operators.
java.lang.String	shutdown() Shutdown a StreamBase server
java.lang.String	shutdown(java.lang.String containerName) Shutdown a container within a StreamBase server
void	shutdownOperators(java.util.List<java.lang.String> operatorNames) Shut down the given Operators on the StreamBase server.
java.lang.String[]	status() Return the status of the StreamBase Server
java.lang.String[]	status(boolean verbose) Return the status of the StreamBase Server
void	suspend(java.lang.String name) Suspend (pause) a container or operator within a StreamBase Server
void	suspendOperators(java.util.List<java.lang.String> operatorNames) Suspend (pause) the given Operators on the StreamBase Server

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamBaseAdminClient

public StreamBaseAdminClient()
                      throws StreamBaseException

Create a StreamBaseAdminClient. Uses the value of the "streambase.uri" property as the URI, or StreamBaseURI.DEFAULT_URI if this property is undefined.

Throws:

StreamBaseException - on connect error, malformed URI, etc.

See Also:

StreamBaseURI

StreamBaseAdminClient

public StreamBaseAdminClient(StreamBaseURI uri)
                      throws StreamBaseException

Create a StreamBaseAdminClient, connecting to the server at the provided URI.

Throws:

StreamBaseException - on connect error

See Also:

StreamBaseURI

StreamBaseAdminClient

public StreamBaseAdminClient(java.lang.String uri)
                      throws StreamBaseException

Create a StreamBaseAdminClient.

Parameters:

uri - The uri to use of the form: sb://address:port. See StreamBaseURI

Throws:

StreamBaseException - on connect error, malformed URI, etc.

See Also:

StreamBaseURI

StreamBaseAdminClient

public StreamBaseAdminClient(java.util.List<StreamBaseURI> uris)
                      throws StreamBaseException

Create a StreamBaseAdminClient.

Parameters:

uris - a list of StreamBaseURIs. Note: The StreamBaseAdminClient only supports one URI in the list.

Throws:

StreamBaseException - on connect error, malformed URI, etc.

See Also:

StreamBaseURI

StreamBaseAdminClient

public StreamBaseAdminClient(java.util.List<StreamBaseURI> uris,
                             ClientSettings settings)
                      throws StreamBaseException

Create a StreamBaseAdminClient.

Parameters:

uris - a list of StreamBaseURIs. Note: The StreamBaseAdminClient only supports one URI in the list.

settings - client settings

Throws:

StreamBaseException - on connect error, malformed URI, etc.

Since:

7.1

See Also:

StreamBaseURI

Method Detail

close

public void close()

Close/shutdown the connection to the StreamBase server.

Specified by:

close in interface java.lang.AutoCloseable

addDeploy

public java.lang.String[] addDeploy(java.lang.String deployText,
                                    java.lang.String... args)
                             throws StreamBaseException

Add the given deployment file to the server given the text of the file

Parameters:

deployText - String contents of a deployment configuration file (.sbdeploy file)

args - a list of options for the command. Valid options include:

[--verbose]

returns a string indicating a succesful operation

Refer to the sbadmin command and the documentation for additional details

Returns:

array of informational results from the server or empty array if no results

Throws:

StreamBaseException

Since:

7.0

See Also:

StreamBaseAdminClient.addDeploy(File, String...)

addDeploy

public java.lang.String[] addDeploy(byte[] deployText,
                                    java.lang.String... args)
                             throws StreamBaseException

Add the given deployment file to the server given the byte content of the file.

Parameters:

deployText - byte contents of a file that specifies a deployment configuration: a .sbdeploy (StreamBase Deployment) file or a .sbar (StreamBase Archive) file. If it is a StreamBase Archive file, the file must have been created by running sbargen on an .sbdeploy file.

args - a list of options for the command. Valid options include:

[--verbose]

returns a string indicating a succesful operation

Refer to the sbadmin command and the documentation for additional details

Returns:

array of informational results from the server or empty array if no results

Throws:

StreamBaseException

Since:

7.0

See Also:

StreamBaseAdminClient.addDeploy(File, String...)

addDeploy

public java.lang.String[] addDeploy(java.io.File deployFile,
                                    java.lang.String... options)
                             throws StreamBaseException

Adds applications and containers defined in the given deployment or archive file to the StreamBase server.

Parameters:

deployFile - File that specifies a deployment configuration: a .sbdeploy (StreamBase Deployment) file or a .sbar (StreamBase Archive) file. If it is a StreamBase Archive file, the file must have been created by running sbargen on an .sbdeploy file.

options - a list of options for the added command. Valid options include:

[--verbose]

returns a string indicating a succesful operation

Refer to the sbadmin command and the documentation for additional details

Returns:

array of informational results from the server or empty array if no results

Throws:

StreamBaseException - if the deployment file is invalid, any of the containers that would be added is invalid, or there is a name collision that prevents a container from being added.

Since:

7.0

addContainer

public java.lang.String[] addContainer(java.lang.String containerName,
                                       java.lang.String applicationText,
                                       java.util.List<java.lang.String> options)
                                throws StreamBaseException

Add the given application to the given container in the StreamBase server

Parameters:

containerName - the container name to add the application under

applicationText - contents of an application: xml from an EventFlow application, or StreamSQL text. The character set is assumed UTF-8.

options - List of options for the added container. See StreamBaseAdminClient.addContainer(String, byte[], List) for details.

Returns:

array of informational results from the server or empty array if no results

Throws:

StreamBaseException - thrown on typecheck and other errors

Since:

6.4 --parameter

addContainer

public java.lang.String[] addContainer(java.lang.String containerName,
                                       byte[] application,
                                       java.util.List<java.lang.String> options)
                                throws StreamBaseException

Add the given application to the given container in the StreamBase server

Parameters:

containerName - the container name to add the application under

application - contents of an application: binary content from a .sbar file, xml from an EventFlow application, or StreamSQL text. The character set is assumed UTF-8.

options - a list of options for the added container. Valid options include:

newContainer.newStream=oldContainer.oldStream

sets up a cross-container connection. You may specify more than one of this option.

--parameter=paramName=paramValue

sets a module parameter (or overrides a default value) for this container's top level application. You may specify more than one of this option.

--suspend

sets the container to the suspended state when added

--enqueue=STREAMSTATUS, --dequeue=STREAMSTATUS

sets the enqueue or dequeue status for this container. STREAMSTATUS is one of ENABLED, DISABLED, DROP_TUPLES. You may specify each option at most once.

--moduleSearch=DIR

adds a directory for the server to locate modules in while adding this container. You may specify more than one of this option.

--datadir=DIR

sets the data directory for this container. You may specify this option only once.

--traceStreamPattern=pattern, --traceFileBase=basefilename, --traceCompress, --traceOverwrite

sets options for runtime tracing for this container. Please see the documentation for details on how to enable and configure runtime tracing

[--verbose]

returns a string indicating a successsful operation

Refer to the sbadmin command and the documentation for additional details on container options.

Returns:

array of informational results from the server or empty array if no results

Throws:

StreamBaseException - thrown on typecheck and other errors

Since:

6.4 added additional tracing options, and the ability to set module parameters for the top-level container application

addContainer

public java.lang.String[] addContainer(java.lang.String containerName,
                                       java.io.File application,
                                       java.util.List<java.lang.String> options)
                                throws StreamBaseException

Add the given application to the given container in the StreamBase server

Parameters:

containerName - the container name to add the application under

application - File that specifies an application: a .sbar file, an EventFlow application, or a StreamSQL application text.

options - List of options for the added container. See StreamBaseAdminClient.addContainer(String, byte[], List) for details

Returns:

array of informational results from the server or empty array if no results

Throws:

StreamBaseException - thrown on typecheck and other errors

Since:

6.2

getOperatorProperties

public java.lang.String[] getOperatorProperties(java.lang.String operatorName)
                                         throws StreamBaseException

For the given Operator, return its set of properties and their values.

Parameters:

operatorName - The operator whose properties are retrieved.

Returns:

array of results or empty array if no results

Throws:

StreamBaseException

getOperatorProperty

public java.lang.String getOperatorProperty(java.lang.String operatorName,
                                            java.lang.String propertyName)
                                     throws StreamBaseException

Return the value of the given property on the given Operator.

Parameters:

operatorName - The operator whose property value is retrieved.

propertyName - The property whose value is retrieved.

Throws:

StreamBaseException

setOperatorProperty

public void setOperatorProperty(java.lang.String operatorName,
                                java.lang.String propertyName,
                                java.lang.String value)
                         throws StreamBaseException

On the given Operator, set the given property to the given value.

Parameters:

operatorName - The operator whose property value is set.

propertyName - The property whose value is set.

value - The value set.

Throws:

StreamBaseException

removeContainer

public java.lang.String[] removeContainer(java.lang.String containerName,
                                          java.lang.String... args)
                                   throws StreamBaseException

Remove the given container in the StreamBase server

Parameters:

containerName - the containerName

args - a list of options for the command. Valid options include:

[--verbose]

returns a string indicating a succesful operation

Refer to the sbadmin command and the documentation for additional details

Returns:

array of informational results from the server or empty array if no results

Throws:

StreamBaseException - thrown on error

restartOperators

public void restartOperators(java.util.List<java.lang.String> operatorNames)
                      throws StreamBaseException

Restart the given Operators on the StreamBase server. The Operators must currently be shut down.

Throws:

StreamBaseException

restartContainer

public java.lang.String[] restartContainer(java.lang.String containerName)
                                    throws StreamBaseException

Throws:

StreamBaseException

fastForwardTime

public void fastForwardTime(java.lang.String msecs)
                     throws StreamBaseException

Throws:

StreamBaseException

getTargetTime

public java.lang.String getTargetTime()
                               throws StreamBaseException

Throws:

StreamBaseException

getEvalCacheContent

public java.lang.String getEvalCacheContent(java.lang.String containerName)
                                     throws StreamBaseException

Throws:

StreamBaseException

clearEvalCache

public java.lang.String clearEvalCache(java.lang.String containerName)
                                throws StreamBaseException

Throws:

StreamBaseException

getMapperCacheContent

public java.lang.String getMapperCacheContent(java.lang.String containerName)
                                       throws StreamBaseException

Throws:

StreamBaseException

resumeOperators

public void resumeOperators(java.util.List<java.lang.String> operatorNames)
                     throws StreamBaseException

Resume the given Operators on the StreamBase server

Throws:

StreamBaseException

resume

public void resume(java.lang.String containerName)
            throws StreamBaseException

Resume a container in a StreamBase server

Parameters:

containerName - the name of the container

Throws:

StreamBaseException

shutdown

public java.lang.String shutdown()
                          throws StreamBaseException

Shutdown a StreamBase server

Throws:

StreamBaseException - thrown on network or other errors

shutdown

public java.lang.String shutdown(java.lang.String containerName)
                          throws StreamBaseException

Shutdown a container within a StreamBase server

Parameters:

containerName - the name of the container

Throws:

StreamBaseException - thrown on network or other errors

shutdownOperators

public void shutdownOperators(java.util.List<java.lang.String> operatorNames)
                       throws StreamBaseException

Shut down the given Operators on the StreamBase server.

Throws:

StreamBaseException

suspendOperators

public void suspendOperators(java.util.List<java.lang.String> operatorNames)
                      throws StreamBaseException

Suspend (pause) the given Operators on the StreamBase Server

Throws:

StreamBaseException - thrown on network or other errors

suspend

public void suspend(java.lang.String name)
             throws StreamBaseException

Suspend (pause) a container or operator within a StreamBase Server

Parameters:

name - the name of the container or operator

Throws:

StreamBaseException - thrown on network or other errors

drain

public void drain()
           throws StreamBaseException

Drain a StreamBase Server Has no effect if the server is not running

Throws:

StreamBaseException - thrown on network or other errors

drain

public void drain(java.lang.String containerName)
           throws StreamBaseException

Drain a container within a StreamBase Server Has no effect if the server is not running

Parameters:

containerName - the name of the container

Throws:

StreamBaseException - thrown on network or other errors

listConnections

public java.lang.String[] listConnections(StreamBaseAdminClient.ListConnectionArgument... args)
                                   throws StreamBaseException

Return an array of client connections

Parameters:

args - arguments for the command

Returns:

an array of client connections

Throws:

StreamBaseException - thrown on network or other errors

listEntities

public java.lang.String[] listEntities(java.lang.String entityType,
                                       int flags)
                                throws StreamBaseException

Return an array of entity names for the given entity type

Parameters:

entityType - the entity type to do the lookup

flags - FULLY_QUALIFIED_NAMES and INCLUDE_MODULES flags

Returns:

an array of entity names for the given entity type

Throws:

StreamBaseException - thrown on network or other errors

killAllConnections

public java.lang.String[] killAllConnections()
                                      throws StreamBaseException

Kill all of the connections on the server

Returns:

status of kill command

Throws:

StreamBaseException

killConnection

public java.lang.String[] killConnection(byte[] connectionId)
                                  throws StreamBaseException

Kill the connection with the given connectionId

Parameters:

connectionId -

Returns:

status of kill command

Throws:

StreamBaseException

manageJdbcConnections

public java.lang.String[] manageJdbcConnections(java.util.List<java.lang.String> args)
                                         throws StreamBaseException

Manage JDBC connections:

count [name]

Count the open JDBC connections to the named data source (or all data sources if ommitted)

close [name]

Close any open JDBC connections to the named data source (or all data sources if ommitted)

Parameters:

args - a list that must contain at least one command string (close or count), and may contain an optional second argument string (the name of a data source). When no argument string is given, the command will apply to all data sources.

Returns:

for close, one string containing the number of connections closed. for count, one string containing the number of open connections

Throws:

StreamBaseException - throw on network or other errors

Since:

7.2

setRuntimeParam

public void setRuntimeParam(java.lang.String paramName,
                            java.lang.String paramValue,
                            java.lang.String operator)
                     throws StreamBaseException

Set a runtime parameter on one, or all, operators. If the operator name is null, the parameter is changed on all operators.

Parameters:

paramName - the runtime parameter name to modify

paramValue - the new value

operator - the target operator to notify for this parameter change, or null to notify all operators

Throws:

StreamBaseException - thrown on network or other errors

modifyContainer

public java.lang.String[] modifyContainer(java.lang.String containerName,
                                          java.util.List<java.lang.String> options)
                                   throws StreamBaseException

Modifies the given container. Only one command may be issued per method invocation.

Parameters:

containerName - the container name to modify

options - a modify command String as the first entry, and any arguments required by that command as subsequent String entries. Valid modify commands and arguments are:

[addConnection|removeConnection] destinationContainer.destinationStream=sourceContainer.sourceStream

adds or removes an asynchronous container connection specified by this command's argument

[addConnection|removeConnection] destinationContainer.destinationStream:=sourceContainer.sourceStream

adds or removes a synchronous container connection specified by this command's argument

[--enqueue=STREAMSTATUS|--dequeue=STREAMSTATUS]

sets the enqueue or dequeue status for this container. STREAMSTATUS is one of ENABLED, DISABLED, DROP_TUPLES. You may only specify one option per invocation of this method.

trace [--traceStreamPattern=pattern] [--traceFileBase=baseFilename] [--traceOverwrite] [--traceCompress] [true|false]

Enables runtime tracing using the provided tracing options, or disable tracing for this container. The last argument must be one of true or false.

--traceFileBase=basefilename

Changes the trace filename prefix

[--traceOverwrite|--traceCompress] [true|false]

Enables or disables overwriting and compressing of trace files

[--verbose]

reports a successful modifyContainer call

Refer to the sbadmin command and the documentation for additional details on container options.

Returns:

array of informational results from the server or empty array if no results

Throws:

StreamBaseException - thrown on errors

Since:

6.4 added tracing options

getLeadershipStatus

public Constants.LeadershipStatus getLeadershipStatus()
                                               throws StreamBaseException

Get the leadership status of the server.

Throws:

StreamBaseException

setLeadershipStatus

public void setLeadershipStatus(Constants.LeadershipStatus leadershipStatus)
                         throws StreamBaseException

Set the leadership status of the server.

Parameters:

leadershipStatus -

Throws:

StreamBaseException

haModeOn

protected boolean haModeOn()

is HA mode on

Returns:

if HA mode is on

getSettings

public ClientSettings getSettings()

Return the settings for this client

Returns:

settings for this client

status

public java.lang.String[] status()
                          throws StreamBaseException

Return the status of the StreamBase Server

Returns:

the status

Throws:

StreamBaseException - thrown on network and other errors

status

public java.lang.String[] status(boolean verbose)
                          throws StreamBaseException

Return the status of the StreamBase Server

Parameters:

verbose - return a verbose status

Returns:

the status

Throws:

StreamBaseException - thrown on network and other errors

operatorStatus

public java.lang.String[] operatorStatus(java.lang.String containerName)
                                  throws StreamBaseException

Return the status of all the operators in the specified container

Parameters:

containerName - the name of the container

Returns:

an array of strings of the form "operatorname=status"

Throws:

StreamBaseException

getURI

public StreamBaseURI getURI()

Return the URI used by this Client. In HA mode this just returns the 1st URI for the client

Returns:

the uri for this client

getURIs

public java.util.List<StreamBaseURI> getURIs()

get all of the URI's for this client

Returns:

all of the URI's for this client