| Interface | Description |
|---|---|
| DeploymentUnitStateCalculator |
Calculates the overall status for a deployment unit (stream or job).
|
| ModuleDeploymentPropertiesProvider<P extends ModuleDeploymentProperties> |
Callback interface to obtain
ModuleDeploymentProperties
for a ModuleDescriptor. |
| Class | Description |
|---|---|
| AdminServerApplication | |
| ApplicationUtils | |
| ArrivingContainerModuleRedeployer |
The
ModuleRedeployer that deploys the unallocated stream/job modules upon a new container arrival. |
| ContainerListener |
Listener implementation that is invoked when containers are added/removed/modified.
|
| ContainerRegistrar |
An instance of this class, registered as a bean in the context for a Container, will handle the registration of that
Container's metadata with ZooKeeper by creating an ephemeral node.
|
| ContainerServerApplication |
The boot application class for a Container server.
|
| DefaultModuleDeploymentPropertiesProvider |
Default implementation that retrieves the
ModuleDeploymentProperties for the given
ModuleDescriptor. |
| DefaultStateCalculator |
Default
DeploymentUnitStateCalculator
implementation for streams and jobs. |
| DepartingContainerModuleRedeployer |
The
ModuleRedeployer that re-deploys the stream/job modules that were
deployed into the departing container. |
| DeploymentLoader |
Utility for loading streams and jobs for the purpose of deployment.
|
| DeploymentSupervisor |
Process that watches ZooKeeper for Container arrivals and departures from
the XD cluster.
|
| InitialDeploymentListener |
Abstract deployment listener that handles fresh stream/job deployment requests.
|
| JobDeploymentListener |
Listener implementation that handles job deployment requests.
|
| ModuleDeploymentStatus |
Status of a module deployment for a container.
|
| ModuleDeploymentWriter |
Utility class to write module deployment requests under
/xd/deployments/modules. |
| ModuleRedeployer |
Abstract ModuleRedeployer that deploy/re-deploys the unallocated/orphaned modules.
|
| ModuleRedeployer.ModuleDeployment |
Holds information about a module that needs to be re-deployed.
|
| ParentConfiguration |
Beans defined and imported here are in the global parent context, hence available to the entire hierarchy, including
Admins, Containers, and Modules.
|
| RuntimeModuleDeploymentPropertiesProvider |
Default implementation of
ModuleDeploymentPropertiesProvider
for type RuntimeModuleDeploymentProperties. |
| SharedServerContextConfiguration |
Beans defined and imported here are shared by the XD Admin Server and Container Server.
|
| SharedServerContextConfiguration.ZookeeperConnectionConfig | |
| SingleNodeApplication |
Single Node XD Runtime.
|
| StreamDeploymentListener |
Listener implementation that handles stream deployment requests.
|
| StreamRuntimePropertiesProvider |
RuntimeModuleDeploymentPropertiesProvider that provides the stream partition/short circuit
properties for the given ModuleDescriptor. |
| Enum | Description |
|---|---|
| ModuleDeploymentStatus.State |
Module deployment states.
|
| Exception | Description |
|---|---|
| AdminPortNotAvailableException |
Exception thrown when the configured admin port is not available to use.
|