All Classes

Class	Description
AlertMessage	A message that should be sent to a configured alert provider.
AlertProviderConfiguration	Configuration for an alert provider.
AppEndpoint	The MessageDispatcher sends messages to a DigitalTwin
AppEndpointException	Thrown if an error occurs while sending a message to a DigitalTwin
AwsIotAction	Enum AwsIotAction defines the supported actions when registering a device through the AwsIotHub with ScaleOut StreamServer.
AwsIotConnectorGridMetadata
AwsIotConnectorGridStartup
AwsIotConnectorMain
AwsIotEndpoint	The AwsIotEndpoint is used to establish a running grid that connects into AwsIoT Core.
AwsIotEndpointBuilder	The AwsIotEndpointBuilder is used to create an endpoint between AWS IoT Core and the digital twin's ExecutionEnvironment (Deployed Model).
AwsIotEndpointException	Thrown if an error occurs while establishing the AwsIotEndpoint grid.
AwsIotMultiplexer	The AwsIotMultiplexer handles incoming messages from AWS IoT core
AwsIotObservingSubscriber	The AwsIotObservingSubscriber handles establishing new connections with AWS IoT core and reposting messages from AWS IoT core to established DigitalTwins.
AwsIotSubscriptionManager	Manages subscriptions to AWS IoT hub.
AwsIotSubscriptionMetadata	The AwsIotSubscription metadata stored information about a connected data source.
AzureDigitalTwinPersistentStorage<V extends DigitalTwinBase>	Persistent storage for AzureDigitalTwins - transparently store and load digital twins to and from Azure Digital Twins.
AzureDigitalTwinsPersistenceProvider	AzureDigitalTwinsPersistenceProvider is a persistence provider implementation that is backed by Azure Digital Twins.
CacheOperationStatus	Status of a cache operation.
CacheResult	Represents a response from a SharedData operation.
ConnectorGridMetadata
ConsumerRecordFilter	Used to filter incoming messages from a Kafka topic.
ConsumerRecordFilterMetadata	The return value for a ConsumerRecordFilter.
CosmosDbPersistenceProvider<V extends DigitalTwinBase>	CosmosDB persistent storage - transparently store and load digital twins to and from an Azure CosmosDB deployment.
DefaultPersistentStorage<V extends DigitalTwinBase>	Default persistent storage - transparently store and load digital twins to and from the configured default persistent storage.
DigitalTwinBase	A real-time digital twin of a data source.
DigitalTwinCosmosRow	Digital Twin instance serialized to a cosmos row.
DigitalTwinKafkaConnection	Abstraction to send a message to a Kafka Broker through a Digital Twin connector.
DigitalTwinKafkaConnectionFactory	Utility class to retrieve a DigitalTwinKafkaConnection
DigitalTwinMain	Hosts a digital twin configured through model.json
DigitalTwinRegistrationException	Thrown if a Digital Twin could not be registered with the processing engine.
DigitalTwinTimerMessage	A message sent to a digital twin instance's message processor.
DigitalTwinWorker	DigitalTwinWorker orchestrates DigitalTwin model and ScaleOut event registration.
DynamoDbPersistenceProvider<V extends DigitalTwinBase>	DynamoDB persistent storage - transparently store and load digital twins to and from a DynamoDB deployment.
FilterResult
GridServices	Utility class for Grid access.
IdStatus
InitContext	The InitContext is passed as a parameter to the DigitalTwinBase.init(InitContext) method of an initializing digital twin.
InitSimulationContext	The InitSimulationContext is passed as a parameter to the SimulationProcessor.onInitSimulation(InitSimulationContext, DigitalTwinBase, Date) method of digital twin instance when a simulation is initializing.
KafkaConnectorGridStartup
KafkaConnectorMain
KafkaDeploymentException	Thrown if an error occurs connecting to Kafka, establishing the connector grid, or other exception occurs
KafkaEndpoint	Creates a KafkaEndpoint which can be used to consume and produce messages from and to Kafka.
KafkaEndpointBuilder	The KafkaEndpointBuilder is used to create an endpoint between a Kafka server and the DigitalTwin execution environment.
LogMessage	A messaged that was logged by a digital twin.
MembershipState
MembershipState
MessageFactory	Message list factory retrieves message lists for a MessageProcessor
MessageProcessor<T extends DigitalTwinBase,V>	Processes messages for a real-time digital twin.
MessageProcessorBase<T extends DigitalTwinBase>	Base class for the MessageProcessor to help with typing.
ModelSchema	The ModelSchema class is used as a Java object representation of the model.json schema file used for deploying a digital twin model to the real-time digital twin cloud service.
PersistenceProvider	An interface that can be used for persisting/retrieving the state of real-time digital twins.
PersistenceProviderType	Available PersistenceProvider types.
PersistentStorage<V extends DigitalTwinBase>	Persistent storage base class
ProcessingContext	Context object that allows the user to send a message to a DataSource.
ProcessingResult	The result from a message processor which indicates to update the state object or to ignore
ProducerObserver
RegistrationMessage	The RegisterMessage is used to register and deregister devices with the AWS IoT core connector.
SendingResult	Marks a message as Delivered or not Delivered
SharedData	SharedData is used to access a model's, or globally, shared cache.
SimulationController	The SimulationController interface is used to interact with the running DigitalTwin simulation.
SimulationEventResult	A simulation event result.
SimulationProcessor<T extends DigitalTwinBase>	Processes simulation events for a digital twin.
SimulationStatus	The status of a simulation.
SimulationStep	The simulation step class encases the metadata for a completed interval of a simulation.
SqlitePersistentStorage<V extends DigitalTwinBase>	SQLite persistent storage - transparently store and load digital twins to and from the a SQLite database (single-server only).
SqlServerPersistentStorage<V extends DigitalTwinBase>	SQLServer persistent storage - transparently store and load digital twins to and from a SQL Server database.
TimerActionResult	The result of a timer action.
TimerHandler<T extends DigitalTwinBase>	Callback to a handle a timer message for a DigitalTwinBase.
TimerMetadata<T extends DigitalTwinBase>	Metadata class for a timer.
TimerType	Enum representation of the available timer types
Workbench	The Workbench is used to represent an environment where developers can test real-time and simulated digital twins.
WorkbenchException	A Workbench exception indicates that a real-time or simulated twin caused an exception.