Constant Field Values

Contents

• com.streambase.*

com.streambase.*

com.streambase.sb.Schema

public static final int	HEADER_SIZE	4
public static final int	NO_SUCH_FIELD	-1
public static final int	STRING_HEADER_SIZE	4
public static final int	UUID_LENGTH	16

com.streambase.sb.Timestamp

public static final long	INTERVAL	1L
public static final long	TIMESTAMP	0L

com.streambase.sb.Tuple

public static final String

NULL_STRING

"null"

com.streambase.sb.client.ClientProperties

public static final String	MAX_QUEUE_SIZE_PROP	"streambase.max-queue-size"
public static final int	MAX_TUPLES_IN_QUEUE_DEFAULT	10000
public static final String	MAX_TUPLES_IN_QUEUE_PROP	"streambase.client.max-tuples-in-queue"
public static final String	READ_BUF_SIZE_PROP	"streambase.read-buf-size"
public static final String	RECONNECT_SLEEP_PROP	"streambase.reconnect-sleep"
public static final String	TUPLE_CONNECTION_QUIESCENT_LIMIT_PROP	"streambase.tuple-connection-quiescent-limit"
public static final String	TUPLE_CONNECTION_TIMEOUT_PROP	"streambase.tuple-connection-timeout"
public static final String	WRITE_BUF_SIZE_PROP	"streambase.write-buf-size"

com.streambase.sb.client.DequeueResult

public static final int	CLOSED	2
public static final int	GOOD	0
public static final int	TIMEOUT	1

com.streambase.sb.client.SSLUtils

public static final String

TRUST_ALGORITHM

"sunx509"

com.streambase.sb.client.StreamBaseClient

public static final int	FULLY_QUALIFIED_NAMES	1
public static final int	INCLUDE_MODULES	2
public static final int	NO_FLAGS	0

com.streambase.sb.client.StreamBaseURI

public static final String	DEFAULT_CONTAINER	"default"
public static final String	DEFAULT_HOST	"localhost"
public static final int	DEFAULT_PORT	10000
public static final String	KEYSTORE_PARAM	"keystore"
public static final String	KEYSTORE_PASS_PARAM	"keypass"
public static final String	NO_CONTAINER	""
public static final String	PASSWORD_PARAM	"password"
public static final String	SECONDARY_HOST_PARAM	"host2"
public static final String	SECONDARY_PORT_PARAM	"port2"
public static final String	SYSTEM_CONTAINER	"system"
public static final String	USER_PARAM	"user"

com.streambase.sb.client.XmlRpcAdmin

public static final String	CONNECTION_ID_STRING	"connectionid"
public static final String	PROTOCOL_STRING	"protocol"

com.streambase.sb.client.XmlRpcCommands

public static final String	ADD_CONTAINER	"addContainer"
public static final String	AUTHENTICATE	"authenticate"
public static final String	CHECKPOINT	"checkpoint"
public static final String	CLUSTER_FINDENTITY	"clusterFindEntity"
public static final int	CLUSTER_FINDENTITY_NODEMANAGER_INDEX	1
public static final int	CLUSTER_FINDENTITY_SBD_INDEX	0
public static final String	CLUSTER_SHUTDOWN	"clusterShutdown"
public static final String	CLUSTER_SHUTDOWN_NODES	"clusterShutdownNodes"
public static final String	CLUSTER_START	"clusterStart"
public static final String	DESCRIBE	"describe"
public static final String	DRAIN	"drain"
public static final String	FAILOVER	"failover"
public static final String	GET_OPERATOR_PROPERTIES	"getOperatorProperties"
public static final String	GET_OPERATOR_PROPERTY	"getOperatorProperty"
public static final String	GET_SCHEMA_BY_HASH	"getSchemaByHash"
public static final String	GET_SCHEMA_BY_NAME	"getSchemaByName"
public static final String	GET_STREAM_PROPERTIES	"getStreamProperties"
public static final String	GET_STREAM_PROPERTIES_BY_HASH	"getStreamPropertiesByHash"
public static final String	INTERNAL_COMMAND	"internalCommand"
public static final String	KILL_CONNECTIONS	"killConnections"
public static final String	LIST_CONNECTIONS	"listConnections"
public static final String	LIST_ENTITIES	"listEntities"
public static final String	LOAD_CHECKPOINT	"loadCheckpoint"
public static final String	MODIFY_APPLICATION	"modifyApplication"
public static final String	OPERATOR_STATUS	"operatorStatus"
public static final String	REMOVE_CONTAINER	"removeContainer"
public static final String	RESTART_OPERATORS	"restartOperators"
public static final String	RESUME	"resume"
public static final String	RESUME_OPERATORS	"resumeOperators"
public static final String	SET_OPERATOR_PROPERTY	"setOperatorProperty"
public static final String	SET_RUNTIME_PARAM	"setRuntimeParam"
public static final String	SHUTDOWN	"shutdown"
public static final String	SHUTDOWN_MANAGER	"shutdownManager"
public static final String	SHUTDOWN_OPERATORS	"shutdownOperators"
public static final String	SHUTDOWN_SECONDARY	"shutdownSecondary"
public static final String	STATUS	"status"
public static final String	SUBSCRIBE	"subscribe"
public static final String	SUSPEND	"suspend"
public static final String	SUSPEND_OPERATORS	"suspendOperators"
public static final String	TYPECHECK	"typecheck"
public static final String	UNSUBSCRIBE	"unsubscribe"

com.streambase.sb.operator.Operator

public static final int

DEFAULT_STATE_CHANGE_TIMEOUT

10000

com.streambase.sb.operator.Operator.OperatorStates

public static final int	NOT_YET_STARTED	0
public static final int	SHUTDOWN	3
public static final int	STARTED	1
public static final int	SUSPENDED	2

com.streambase.sb.operator.Operator.SuspendBehaviorStates

public static final int	DROPPING_TUPLES	1
public static final int	PROCESSING_TUPLES	2