- Schema - Class in com.sybase.esp.sdk.data
-
This class provides methods to retrieve the structure of data in a stream, including
column names, column types, key columns, etc.
- Schema(List<String>, List<Schema.DataType>, List<Boolean>) - Constructor for class com.sybase.esp.sdk.data.Schema
-
- Schema.DataType - Enum in com.sybase.esp.sdk.data
-
Data types supported by ESP.
- SDK - Class in com.sybase.esp.sdk
-
This is the main entry point to the SDK.
- SDK.AccessMode - Enum in com.sybase.esp.sdk
-
Enumeration of access mode types.
- SdkEvent<E extends java.lang.Enum<E>> - Interface in com.sybase.esp.sdk
-
- SdkEvent.Category - Enum in com.sybase.esp.sdk
-
- SdkEventError<E extends java.lang.Enum<E>> - Class in com.sybase.esp.sdk
-
- SdkEventError(String, Throwable, E) - Constructor for class com.sybase.esp.sdk.SdkEventError
-
- select() - Method in interface com.sybase.esp.sdk.Selector
-
Blocks until one or more registered entities have an event pending
- Selector - Interface in com.sybase.esp.sdk
-
- selectWith(Selector, EnumSet<E>) - Method in interface com.sybase.esp.sdk.DispatchableEntity
-
- sendHeartbeat() - Method in interface com.sybase.esp.sdk.data.Publisher
-
Sends a heartbeat message to the connected engine on this publishers socket.
- Server - Interface in com.sybase.esp.sdk
-
A
Server instance represents a running ESP cluster.
- Server.AffinityCharge - Enum in com.sybase.esp.sdk
-
- Server.AffinityStrength - Enum in com.sybase.esp.sdk
-
- Server.AffinityType - Enum in com.sybase.esp.sdk
-
- Server.Application - Interface in com.sybase.esp.sdk
-
Application entities known to the server framework
- Server.Application.Affinity - Interface in com.sybase.esp.sdk
-
- Server.Application.Instance - Interface in com.sybase.esp.sdk
-
- Server.Application.Type - Enum in com.sybase.esp.sdk
-
- Server.Controller - Interface in com.sybase.esp.sdk
-
Controllers in the server
- Server.Manager - Interface in com.sybase.esp.sdk
-
Corresponds to an instance of Manager process running in the server framework
- Server.Status - Enum in com.sybase.esp.sdk
-
- ServerController - Class in com.sybase.esp.sdk
-
This class provides facilities for controlling and monitoring a cluster.
- ServerController() - Constructor for class com.sybase.esp.sdk.ServerController
-
- ServerController.ApplicationConfig - Class in com.sybase.esp.sdk
-
Encapsulates application deployment information for deploying a project to a server.
- ServerController.ApplicationConfig.Option - Enum in com.sybase.esp.sdk
-
- ServerController.InstanceConfig - Class in com.sybase.esp.sdk
-
Class encapsulating configuration information about an application instance.
- ServerErrorException - Exception in com.sybase.esp.sdk.exception
-
- ServerErrorException(Map<String, Object>) - Constructor for exception com.sybase.esp.sdk.exception.ServerErrorException
-
- ServerErrorException(String) - Constructor for exception com.sybase.esp.sdk.exception.ServerErrorException
-
- ServerEvent - Class in com.sybase.esp.sdk
-
Events that can occur on a server object.
- ServerEvent(Server, ServerEvent.Type) - Constructor for class com.sybase.esp.sdk.ServerEvent
-
- ServerEvent.Type - Enum in com.sybase.esp.sdk
-
- ServerOptions - Class in com.sybase.esp.sdk
-
- ServerOptions.Builder - Class in com.sybase.esp.sdk
-
- ServerOptions.Builder() - Constructor for class com.sybase.esp.sdk.ServerOptions.Builder
-
- setAccessMode(SDK.AccessMode) - Method in class com.sybase.esp.sdk.data.PublisherOptions.Builder
-
Set the access mode to use for the publisher.
- setAccessMode(SDK.AccessMode) - Method in class com.sybase.esp.sdk.data.SubscriberOptions.Builder
-
- setAccessMode(SDK.AccessMode) - Method in class com.sybase.esp.sdk.ProjectOptions.Builder
-
- setAccessMode(SDK.AccessMode) - Method in class com.sybase.esp.sdk.ServerOptions.Builder
-
- setAppName(String) - Method in class com.sybase.esp.sdk.Credentials.Builder
-
Application name to pick up login context configuration.
- setAsyncPublishing(boolean) - Method in class com.sybase.esp.sdk.data.PublisherOptions.Builder
-
If set to false a publish wait for servers response after each send.
- setAuthenticationDetails(String, String, String) - Method in class com.sybase.esp.sdk.Credentials.Builder
-
- setBaseDrainTimeout(int) - Method in class com.sybase.esp.sdk.data.SubscriberOptions.Builder
-
Set the maximum time server will allow for a client to read in the base data
after a connection is established.
- setBigDatetime(BigDatetime) - Method in interface com.sybase.esp.sdk.data.RelativeRowWriter
-
- setBinary(byte[]) - Method in interface com.sybase.esp.sdk.data.RelativeRowWriter
-
- setBlockingMode(PublisherOptions.BlockingMode) - Method in class com.sybase.esp.sdk.data.PublisherOptions.Builder
-
Sets the blocking mode to use.
- setBoolean(boolean) - Method in interface com.sybase.esp.sdk.data.RelativeRowWriter
-
- setBuffer(ByteBuffer) - Method in class com.sybase.esp.sdk.data.RawMessageWriter
-
Set the buffet to publish.
- setBufferSize(int) - Method in class com.sybase.esp.sdk.data.PublisherOptions.Builder
-
Sets buffer size to use.
- setCallback(EnumSet<E>, Callback<T>) - Method in interface com.sybase.esp.sdk.DispatchableEntity
-
- setColumnValues(List<Object>) - Method in interface com.sybase.esp.sdk.data.AbsoluteRowWriter
-
Can be used to set the values of all columns.
- setConnectionRetries(int) - Method in class com.sybase.esp.sdk.ProjectOptions.Builder
-
If set to a positive value, and the access mode is either CALLBACK or SELECT, the SDK
will try to automatically reconnect if it detects loss of connection.
- setConnectionRetries(int) - Method in class com.sybase.esp.sdk.ServerOptions.Builder
-
If set to nonzero, the
Server object will try to reconnect to the backend server
even if all managers go down.
- setDate(Date) - Method in interface com.sybase.esp.sdk.data.RelativeRowWriter
-
The DATE data type is provided for compatibility with legacy ASP types.
- setDateFormat(String) - Method in class com.sybase.esp.util.upload.Uploader
-
Ignored for binary uploaders.
- setDelimiter(char) - Method in class com.sybase.esp.util.upload.Uploader
-
Override the default delimiter in delimited uploader.
- setDispatcher(Dispatcher) - Method in class com.sybase.esp.sdk.data.PublisherOptions.Builder
-
- setDispatcher(Dispatcher) - Method in class com.sybase.esp.sdk.data.SubscriberOptions.Builder
-
- setDispatcher(Dispatcher) - Method in class com.sybase.esp.sdk.ProjectOptions.Builder
-
- setDispatcher(Dispatcher) - Method in class com.sybase.esp.sdk.ServerOptions.Builder
-
- setDouble(int, double) - Method in interface com.sybase.esp.sdk.data.AbsoluteRowWriter
-
- setDouble(String, double) - Method in interface com.sybase.esp.sdk.data.AbsoluteRowWriter
-
- setDouble(double) - Method in interface com.sybase.esp.sdk.data.RelativeRowWriter
-
- setDroppable(boolean) - Method in class com.sybase.esp.sdk.data.SubscriberOptions.Builder
-
If set to true, server will drop this connection, if the client cannot keep up.
- setExitOnClose(boolean) - Method in class com.sybase.esp.sdk.data.PublisherOptions.Builder
-
Should the server shutdown if this connection closes.
- setExitOnTimeout(int) - Method in class com.sybase.esp.sdk.data.PublisherOptions.Builder
-
Should the server shutdown if this connection times out.
- setFailover(int, int) - Method in class com.sybase.esp.sdk.ServerController.InstanceConfig
-
- setFinalizerOnTimeout(int, String) - Method in class com.sybase.esp.sdk.data.PublisherOptions.Builder
-
Set the command to run if this connection times out
- setHighPerformance() - Method in class com.sybase.esp.sdk.data.PublisherOptions.Builder
-
A utility function that configures a Publisher for high performance.
- setHistorySize(String, int) - Method in interface com.sybase.esp.sdk.debugger.Debugger
-
- setInputBreakpoint(String, String, int) - Method in interface com.sybase.esp.sdk.debugger.Debugger
-
- setInputBreakpoint(String, String, String, int) - Method in interface com.sybase.esp.sdk.debugger.Debugger
-
- setInteger(int, int) - Method in interface com.sybase.esp.sdk.data.AbsoluteRowWriter
-
- setInteger(String, int) - Method in interface com.sybase.esp.sdk.data.AbsoluteRowWriter
-
- setInteger(int) - Method in interface com.sybase.esp.sdk.data.RelativeRowWriter
-
- setInterval(int, long) - Method in interface com.sybase.esp.sdk.data.AbsoluteRowWriter
-
- setInterval(String, long) - Method in interface com.sybase.esp.sdk.data.AbsoluteRowWriter
-
- setInterval(long) - Method in interface com.sybase.esp.sdk.data.RelativeRowWriter
-
- setKeystore(File, String) - Method in class com.sybase.esp.sdk.Credentials.Builder
-
- setLegacyMoney(Money) - Method in interface com.sybase.esp.sdk.data.RelativeRowWriter
-
- setLong(int, long) - Method in interface com.sybase.esp.sdk.data.AbsoluteRowWriter
-
- setLong(String, long) - Method in interface com.sybase.esp.sdk.data.AbsoluteRowWriter
-
- setLong(long) - Method in interface com.sybase.esp.sdk.data.RelativeRowWriter
-
- setLossy(boolean) - Method in class com.sybase.esp.sdk.data.SubscriberOptions.Builder
-
If set to true, server may discard records, if the client cannot keep up
- setManager(String, int) - Method in class com.sybase.esp.sdk.Uri.Builder
-
Set a manager specification.
- setMoney(int, Money) - Method in interface com.sybase.esp.sdk.data.AbsoluteRowWriter
-
- setMoney(String, Money) - Method in interface com.sybase.esp.sdk.data.AbsoluteRowWriter
-
- setMoney(Money) - Method in interface com.sybase.esp.sdk.data.RelativeRowWriter
-
- setNoBase(boolean) - Method in class com.sybase.esp.sdk.data.SubscriberOptions.Builder
-
If set to true, server does not send data existing in the stream at the time
the subscription is set up
- setNull(int) - Method in interface com.sybase.esp.sdk.data.AbsoluteRowWriter
-
- setNull(String) - Method in interface com.sybase.esp.sdk.data.AbsoluteRowWriter
-
- setNull() - Method in interface com.sybase.esp.sdk.data.RelativeRowWriter
-
- setOperation(Stream.Operation) - Method in interface com.sybase.esp.sdk.data.AbsoluteRowWriter
-
- setOperation(Stream.Operation) - Method in interface com.sybase.esp.sdk.data.RelativeRowWriter
-
- setOperation(Stream.Operation) - Method in class com.sybase.esp.util.upload.Uploader
-
This overrides the opcode in the data being uploaded.
- setOption(int, ByteBuffer) - Method in class com.sybase.esp.sdk.data.MessageWriter
-
- setOutputBreakpoint(String, String, int) - Method in interface com.sybase.esp.sdk.debugger.Debugger
-
- setPassword(String) - Method in class com.sybase.esp.sdk.Credentials.Builder
-
- setPreserveBlocks(boolean) - Method in class com.sybase.esp.sdk.data.SubscriberOptions.Builder
-
If set to true, server preserves the block structure of the data.
- setPrivateKeyFile(File) - Method in class com.sybase.esp.sdk.Credentials.Builder
-
- setProject(String) - Method in class com.sybase.esp.sdk.Uri.Builder
-
The name the project is deployed with.
- setPulseInterval(int) - Method in class com.sybase.esp.sdk.data.SubscriberOptions.Builder
-
Sets a pulse interval.
- setQueueSize(int) - Method in class com.sybase.esp.sdk.data.SubscriberOptions.Builder
-
Set the server gateway internal queue size.
- setServer(String) - Method in class com.sybase.esp.sdk.Uri.Builder
-
Set the cluster details.
- setShineThrough(int, boolean) - Method in interface com.sybase.esp.sdk.data.AbsoluteRowWriter
-
- setShineThrough(String, boolean) - Method in interface com.sybase.esp.sdk.data.AbsoluteRowWriter
-
- setShineThrough() - Method in interface com.sybase.esp.sdk.data.RelativeRowWriter
-
- setShineThrough(boolean) - Method in class com.sybase.esp.sdk.data.SubscriberOptions.Builder
-
Deprecated.
- setSqlPort(int) - Method in class com.sybase.esp.sdk.ServerController.ApplicationConfig
-
Deprecated.
- setSSL(boolean) - Method in class com.sybase.esp.sdk.Uri.Builder
-
Set the ssl mode of the uri.
- setStandaloneSslMode(boolean) - Method in class com.sybase.esp.sdk.Credentials.Builder
-
Set optional encryption on connection to standalone projects.
- setStream(ByteBuffer, Stream) - Static method in class com.sybase.esp.sdk.data.RawMessageWriter
-
Helper that method allows redirecting the buffer to a different stream.
- setStream(String) - Method in class com.sybase.esp.sdk.Uri.Builder
-
Set a stream name.
- setStream(String) - Method in class com.sybase.esp.util.upload.Uploader
-
This overrides the target stream if any in the data being uploaded.
- setString(int, String) - Method in interface com.sybase.esp.sdk.data.AbsoluteRowWriter
-
- setString(String, String) - Method in interface com.sybase.esp.sdk.data.AbsoluteRowWriter
-
- setString(String) - Method in interface com.sybase.esp.sdk.data.RelativeRowWriter
-
- setTimestamp(int, Date) - Method in interface com.sybase.esp.sdk.data.AbsoluteRowWriter
-
- setTimestamp(String, Date) - Method in interface com.sybase.esp.sdk.data.AbsoluteRowWriter
-
- setTimestamp(Date) - Method in interface com.sybase.esp.sdk.data.RelativeRowWriter
-
- setTimestampFormat(String) - Method in class com.sybase.esp.util.upload.Uploader
-
Ignored for binary uploaders.
- setTrace(boolean) - Method in class com.sybase.esp.sdk.Credentials.Builder
-
Deprecated.
- setTraceStream(PrintStream) - Method in class com.sybase.esp.sdk.SDK
-
- setTracing(boolean) - Method in interface com.sybase.esp.sdk.Dispatcher
-
- setUpdater(Updater) - Method in class com.sybase.esp.sdk.data.PublisherOptions.Builder
-
- setUpdater(Updater) - Method in class com.sybase.esp.sdk.data.SubscriberOptions.Builder
-
- setUpdater(Updater) - Method in class com.sybase.esp.sdk.ProjectOptions.Builder
-
- setUpdater(Updater) - Method in class com.sybase.esp.sdk.ServerOptions.Builder
-
- setUser(String) - Method in class com.sybase.esp.sdk.Credentials.Builder
-
- setUserClass(String) - Method in class com.sybase.esp.sdk.Credentials.Builder
-
Not implemented
- setWorkspace(String) - Method in class com.sybase.esp.sdk.Uri.Builder
-
Set the workspace name.
- start() - Method in class com.sybase.esp.sdk.SDK
-
Initializes the SDK for operation which includes steps such as starting internal threads.
- startAdapter(String) - Method in interface com.sybase.esp.sdk.adapter.AdapterController
-
Starts a specified adapter
- startApplication(String, String, int) - Method in class com.sybase.esp.sdk.ServerController
-
Starts an deployed application on the server
- startApplication(String, String, int, int) - Method in class com.sybase.esp.sdk.ServerController
-
Starts an instance of an application on the server
- startApplication(ServerController.ApplicationConfig, int) - Method in class com.sybase.esp.sdk.ServerController
-
Starts an deployed application on the server
- startDebugging() - Method in interface com.sybase.esp.sdk.debugger.Debugger
-
- startDispatcher() - Method in interface com.sybase.esp.sdk.Dispatcher
-
Starts an internal thread that dispatches events on this dispatcher.
- startEnvelope(int) - Method in class com.sybase.esp.sdk.data.MessageWriter
-
Throws an exception if the Publisher has been created with auto blocking.
- startEnvelope() - Method in class com.sybase.esp.sdk.data.RawMessageWriter
-
Start an envelope block
- startRow() - Method in interface com.sybase.esp.sdk.data.RelativeRowWriter
-
- startTransaction(int) - Method in class com.sybase.esp.sdk.data.MessageWriter
-
Throws an exception if the Publisher has been created with auto blocking.
- startTransaction() - Method in class com.sybase.esp.sdk.data.RawMessageWriter
-
Start a transaction block
- startUpdater() - Method in interface com.sybase.esp.sdk.Updater
-
Starts the internal update thread
- status() - Method in enum com.sybase.esp.sdk.Server.Status
-
- step(int) - Method in interface com.sybase.esp.sdk.debugger.Debugger
-
Steps a single row on any stream that is scheduled for running
- stepQuiesceDerivedStreams(int) - Method in interface com.sybase.esp.sdk.debugger.Debugger
-
- stepQuiesceDescendants(String, int) - Method in interface com.sybase.esp.sdk.debugger.Debugger
-
- stepQuiesceStreamAndDescendants(String, int) - Method in interface com.sybase.esp.sdk.debugger.Debugger
-
- stepStream(String, int) - Method in interface com.sybase.esp.sdk.debugger.Debugger
-
Steps the specified stream a single row
- stepTransaction(int) - Method in interface com.sybase.esp.sdk.debugger.Debugger
-
- stop() - Method in class com.sybase.esp.sdk.SDK
-
Decreases start count for the SDK.
- stopAdapter(String) - Method in interface com.sybase.esp.sdk.adapter.AdapterController
-
Stops a specified adapter
- stopApplication(String, String, int) - Method in class com.sybase.esp.sdk.ServerController
-
Stops an application on the server
- stopApplication(ServerController.ApplicationConfig, int) - Method in class com.sybase.esp.sdk.ServerController
-
Stops an application on the server
- stopApplication(String, String, int, int) - Method in class com.sybase.esp.sdk.ServerController
-
Stops an instance of an application on the server
- stopDebugging() - Method in interface com.sybase.esp.sdk.debugger.Debugger
-
- stopDispatcher() - Method in interface com.sybase.esp.sdk.Dispatcher
-
Finishes dispatching any events that may have been queue up, deregisters itself from
all entities, removes this dispatcher from runtime, releasing any resources or links it may
shold.
- stopNode(String) - Method in class com.sybase.esp.sdk.ServerController
-
Stops a cluster node
- stopUpdater() - Method in interface com.sybase.esp.sdk.Updater
-
- Stream - Interface in com.sybase.esp.sdk
-
- Stream.Operation - Enum in com.sybase.esp.sdk
-
Operations suppored in ESP
- Stream.StreamType - Enum in com.sybase.esp.sdk
-
Different stream types supported in ESP.
- Stream.Visibility - Enum in com.sybase.esp.sdk
-
Stream access restrictions
- string() - Method in enum com.sybase.esp.sdk.Server.AffinityCharge
-
- string() - Method in enum com.sybase.esp.sdk.Server.AffinityStrength
-
- string() - Method in enum com.sybase.esp.sdk.Server.AffinityType
-
- string() - Method in enum com.sybase.esp.sdk.Server.Application.Type
-
- string() - Method in enum com.sybase.esp.sdk.ServerController.ApplicationConfig.Option
-
- Subscriber - Interface in com.sybase.esp.sdk.data
-
A Subscriber is used to subscribe to data from one or more streams in a server.
- SubscriberEvent - Class in com.sybase.esp.sdk.data
-
- SubscriberEvent(Subscriber, SubscriberEvent.Type, Stream, MessageReader) - Constructor for class com.sybase.esp.sdk.data.SubscriberEvent
-
- SubscriberEvent.Type - Enum in com.sybase.esp.sdk.data
-
- SubscriberOptions - Class in com.sybase.esp.sdk.data
-
- SubscriberOptions.Builder - Class in com.sybase.esp.sdk.data
-
- SubscriberOptions.Builder() - Constructor for class com.sybase.esp.sdk.data.SubscriberOptions.Builder
-
- subscribeSql(String) - Method in interface com.sybase.esp.sdk.data.Subscriber
-
Starts a projection subscription.
- subscribeStream(String) - Method in interface com.sybase.esp.sdk.data.Subscriber
-
Subscribe to a single stream.
- subscribeStream(Stream) - Method in interface com.sybase.esp.sdk.data.Subscriber
-
Subscribe to a single stream.
- subscribeStreams(String[]) - Method in interface com.sybase.esp.sdk.data.Subscriber
-
Subscribes to multiple streams.
- subscribeStreams(Stream[]) - Method in interface com.sybase.esp.sdk.data.Subscriber
-
Subscribes to streams.