| Package | Description |
|---|---|
| org.apache.whirr |
The Whirr client API.
|
| org.apache.whirr.actions |
A collection of
ClusterAction implementations. |
| org.apache.whirr.cli.command | |
| org.apache.whirr.command | |
| org.apache.whirr.compute | |
| org.apache.whirr.service |
The Whirr Service API.
|
| org.apache.whirr.service.druid |
Package for the Apache Whirr service for Druid
|
| org.apache.whirr.service.elasticsearch | |
| org.apache.whirr.service.ganglia | |
| org.apache.whirr.service.hadoop | |
| org.apache.whirr.service.hama | |
| org.apache.whirr.service.hbase | |
| org.apache.whirr.service.jclouds |
jclouds-specific classes.
|
| org.apache.whirr.service.kerberos | |
| org.apache.whirr.service.yarn | |
| org.apache.whirr.service.zookeeper | |
| org.apache.whirr.state | |
| org.apache.whirr.template | |
| org.apache.whirr.util |
Utility classes.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterSpec |
ClusterSpec.copy()
Create a deep object copy.
|
static ClusterSpec |
ClusterSpec.withNoDefaults()
Create new empty instance for testing.
|
static ClusterSpec |
ClusterSpec.withNoDefaults(org.apache.commons.configuration.Configuration conf) |
static ClusterSpec |
ClusterSpec.withTemporaryKeys()
Create an instance that uses a temporary RSA key pair.
|
static ClusterSpec |
ClusterSpec.withTemporaryKeys(org.apache.commons.configuration.Configuration conf) |
| Modifier and Type | Method and Description |
|---|---|
com.google.common.base.Function<ClusterSpec,org.jclouds.compute.ComputeServiceContext> |
ClusterAction.getCompute() |
com.google.common.base.Function<ClusterSpec,org.jclouds.compute.ComputeServiceContext> |
ClusterController.getCompute() |
| Modifier and Type | Method and Description |
|---|---|
Cluster |
ByonClusterController.bootstrapCluster(ClusterSpec clusterSpec)
Provisions the hardware for a BYON cluster.
|
Cluster |
ClusterController.bootstrapCluster(ClusterSpec clusterSpec)
Provision the hardware resources needed for running services
|
Cluster |
ClusterController.cleanupCluster(ClusterSpec spec)
Remove the cluster services
|
Cluster |
ClusterController.cleanupCluster(ClusterSpec clusterSpec,
Cluster cluster) |
Cluster |
ClusterController.configureServices(ClusterSpec spec)
Configure cluster services
|
Cluster |
ClusterController.configureServices(ClusterSpec clusterSpec,
Cluster cluster) |
Cluster |
ByonClusterController.configureServices(ClusterSpec clusterSpec,
Cluster cluster,
Set<String> targetRoles,
Set<String> targetInstanceIds)
Configures cluster services for a BYON cluster.
|
Cluster |
ClusterController.configureServices(ClusterSpec clusterSpec,
Cluster cluster,
Set<String> targetRoles,
Set<String> targetInstanceIds) |
org.jclouds.compute.options.RunScriptOptions |
ClusterController.defaultRunScriptOptionsForSpec(ClusterSpec spec) |
void |
ByonClusterController.destroyCluster(ClusterSpec clusterSpec)
Destroys a whirr BYON cluster.
|
void |
ClusterController.destroyCluster(ClusterSpec clusterSpec)
Stop the cluster and destroy all resources associated with it.
|
void |
ClusterController.destroyCluster(ClusterSpec clusterSpec,
Cluster cluster) |
void |
ByonClusterController.destroyInstance(ClusterSpec clusterSpec,
String instanceId) |
void |
ClusterController.destroyInstance(ClusterSpec clusterSpec,
String instanceId) |
abstract Cluster |
ClusterAction.execute(ClusterSpec clusterSpec,
Cluster cluster) |
ClusterStateStore |
ClusterController.getClusterStateStore(ClusterSpec clusterSpec) |
Set<Cluster.Instance> |
ClusterController.getInstances(ClusterSpec spec) |
Set<Cluster.Instance> |
ClusterController.getInstances(ClusterSpec spec,
ClusterStateStore stateStore) |
Set<? extends org.jclouds.compute.domain.NodeMetadata> |
ByonClusterController.getNodes(ClusterSpec clusterSpec) |
Set<? extends org.jclouds.compute.domain.NodeMetadata> |
ClusterController.getNodes(ClusterSpec clusterSpec)
Deprecated.
|
Cluster |
ClusterController.launchCluster(ClusterSpec clusterSpec)
Start the cluster described by
clusterSpec and block until the
cluster is
available. |
Map<? extends org.jclouds.compute.domain.NodeMetadata,org.jclouds.compute.domain.ExecResponse> |
ByonClusterController.runScriptOnNodesMatching(ClusterSpec spec,
com.google.common.base.Predicate<org.jclouds.compute.domain.NodeMetadata> condition,
org.jclouds.scriptbuilder.domain.Statement statement) |
Map<? extends org.jclouds.compute.domain.NodeMetadata,org.jclouds.compute.domain.ExecResponse> |
ClusterController.runScriptOnNodesMatching(ClusterSpec spec,
com.google.common.base.Predicate<org.jclouds.compute.domain.NodeMetadata> condition,
org.jclouds.scriptbuilder.domain.Statement statement) |
Map<? extends org.jclouds.compute.domain.NodeMetadata,org.jclouds.compute.domain.ExecResponse> |
ClusterController.runScriptOnNodesMatching(ClusterSpec spec,
com.google.common.base.Predicate<org.jclouds.compute.domain.NodeMetadata> condition,
org.jclouds.scriptbuilder.domain.Statement statement,
org.jclouds.compute.options.RunScriptOptions options) |
Cluster |
ClusterController.startServices(ClusterSpec spec)
Start the cluster services
|
Cluster |
ClusterController.startServices(ClusterSpec clusterSpec,
Cluster cluster) |
Cluster |
ClusterController.startServices(ClusterSpec clusterSpec,
Cluster cluster,
Set<String> targetRoles,
Set<String> targetInstanceIds) |
Cluster |
ClusterController.stopServices(ClusterSpec spec)
Stop the cluster services
|
Cluster |
ClusterController.stopServices(ClusterSpec clusterSpec,
Cluster cluster) |
Cluster |
ClusterController.stopServices(ClusterSpec clusterSpec,
Cluster cluster,
Set<String> targetRoles,
Set<String> targetInstanceIds) |
| Constructor and Description |
|---|
ByonClusterController(com.google.common.base.Function<ClusterSpec,org.jclouds.compute.ComputeServiceContext> getCompute,
ClusterStateStoreFactory stateStoreFactory) |
ClusterAction(com.google.common.base.Function<ClusterSpec,org.jclouds.compute.ComputeServiceContext> getCompute) |
ClusterController(com.google.common.base.Function<ClusterSpec,org.jclouds.compute.ComputeServiceContext> getCompute,
ClusterStateStoreFactory stateStoreFactory) |
| Modifier and Type | Method and Description |
|---|---|
Cluster |
ScriptBasedClusterAction.execute(ClusterSpec clusterSpec,
Cluster cluster) |
com.google.common.util.concurrent.ListenableFuture<org.jclouds.compute.domain.ExecResponse> |
ScriptBasedClusterAction.runStatementOnInstanceInCluster(StatementBuilder statementBuilder,
Cluster.Instance instance,
ClusterSpec clusterSpec,
org.jclouds.compute.options.RunScriptOptions options) |
| Constructor and Description |
|---|
BootstrapClusterAction(com.google.common.base.Function<ClusterSpec,org.jclouds.compute.ComputeServiceContext> getCompute,
com.google.common.cache.LoadingCache<String,ClusterActionHandler> handlerMap) |
ByonClusterAction(String action,
com.google.common.base.Function<ClusterSpec,org.jclouds.compute.ComputeServiceContext> getCompute,
com.google.common.cache.LoadingCache<String,ClusterActionHandler> handlerMap) |
CleanupClusterAction(com.google.common.base.Function<ClusterSpec,org.jclouds.compute.ComputeServiceContext> getCompute,
com.google.common.cache.LoadingCache<String,ClusterActionHandler> handlerMap) |
CleanupClusterAction(com.google.common.base.Function<ClusterSpec,org.jclouds.compute.ComputeServiceContext> getCompute,
com.google.common.cache.LoadingCache<String,ClusterActionHandler> handlerMap,
Set<String> targetRoles,
Set<String> targetInstanceIds) |
ConfigureServicesAction(com.google.common.base.Function<ClusterSpec,org.jclouds.compute.ComputeServiceContext> getCompute,
com.google.common.cache.LoadingCache<String,ClusterActionHandler> handlerMap) |
ConfigureServicesAction(com.google.common.base.Function<ClusterSpec,org.jclouds.compute.ComputeServiceContext> getCompute,
com.google.common.cache.LoadingCache<String,ClusterActionHandler> handlerMap,
Set<String> targetRoles,
Set<String> targetInstanceIds) |
DestroyClusterAction(com.google.common.base.Function<ClusterSpec,org.jclouds.compute.ComputeServiceContext> getCompute,
com.google.common.cache.LoadingCache<String,ClusterActionHandler> handlerMap) |
ScriptBasedClusterAction(com.google.common.base.Function<ClusterSpec,org.jclouds.compute.ComputeServiceContext> getCompute,
com.google.common.cache.LoadingCache<String,ClusterActionHandler> handlerMap) |
ScriptBasedClusterAction(com.google.common.base.Function<ClusterSpec,org.jclouds.compute.ComputeServiceContext> getCompute,
com.google.common.cache.LoadingCache<String,ClusterActionHandler> handlerMap,
Set<String> targetRoles,
Set<String> targetInstanceIds) |
StartServicesAction(com.google.common.base.Function<ClusterSpec,org.jclouds.compute.ComputeServiceContext> getCompute,
com.google.common.cache.LoadingCache<String,ClusterActionHandler> handlerMap) |
StartServicesAction(com.google.common.base.Function<ClusterSpec,org.jclouds.compute.ComputeServiceContext> getCompute,
com.google.common.cache.LoadingCache<String,ClusterActionHandler> handlerMap,
Set<String> targetRoles,
Set<String> targetInstanceIds) |
StopServicesAction(com.google.common.base.Function<ClusterSpec,org.jclouds.compute.ComputeServiceContext> getCompute,
com.google.common.cache.LoadingCache<String,ClusterActionHandler> handlerMap) |
StopServicesAction(com.google.common.base.Function<ClusterSpec,org.jclouds.compute.ComputeServiceContext> getCompute,
com.google.common.cache.LoadingCache<String,ClusterActionHandler> handlerMap,
Set<String> targetRoles,
Set<String> targetInstanceIds) |
| Modifier and Type | Method and Description |
|---|---|
int |
LaunchClusterCommand.run(InputStream in,
PrintStream out,
PrintStream err,
ClusterSpec clusterSpec) |
int |
ListClusterCommand.run(InputStream in,
PrintStream out,
PrintStream err,
ClusterSpec clusterSpec) |
int |
DestroyClusterCommand.run(InputStream in,
PrintStream out,
PrintStream err,
ClusterSpec clusterSpec) |
int |
DestroyInstanceCommand.run(InputStream in,
PrintStream out,
PrintStream err,
ClusterSpec clusterSpec,
String instanceId) |
int |
RunScriptCommand.run(InputStream in,
PrintStream out,
PrintStream err,
ClusterSpec clusterSpec,
String[] instances,
String[] roles,
String fileName) |
int |
RestartServicesCommand.runLifecycleStep(ClusterSpec clusterSpec,
ClusterController controller,
joptsimple.OptionSet optionSet) |
int |
StartServicesCommand.runLifecycleStep(ClusterSpec clusterSpec,
ClusterController controller,
joptsimple.OptionSet optionSet) |
int |
StopServicesCommand.runLifecycleStep(ClusterSpec clusterSpec,
ClusterController controller,
joptsimple.OptionSet optionSet) |
int |
ConfigureServicesCommand.runLifecycleStep(ClusterSpec clusterSpec,
ClusterController controller,
joptsimple.OptionSet optionSet) |
abstract int |
RoleLifecycleCommand.runLifecycleStep(ClusterSpec clusterSpec,
ClusterController controller,
joptsimple.OptionSet optionSet)
Implement this method to trigger the relevant role lifecycle action
|
| Modifier and Type | Method and Description |
|---|---|
protected ClusterSpec |
AbstractClusterCommand.getClusterSpec(joptsimple.OptionSet optionSet)
Load the cluster spec by parsing the command line option set
|
| Modifier and Type | Method and Description |
|---|---|
protected ClusterStateStore |
AbstractClusterCommand.createClusterStateStore(ClusterSpec spec)
Create the cluster state store object
|
protected Cluster |
AbstractClusterCommand.getCluster(ClusterSpec clusterSpec,
ClusterController controller)
Get the cluster instance together with NodeMetadata (through API calls)
|
protected void |
AbstractClusterCommand.printProviderInfo(PrintStream out,
PrintStream err,
ClusterSpec clusterSpec,
joptsimple.OptionSet optionSet) |
| Modifier and Type | Method and Description |
|---|---|
static org.jclouds.compute.domain.Template |
BootstrapTemplate.build(ClusterSpec clusterSpec,
org.jclouds.compute.ComputeService computeService,
StatementBuilder statementBuilder,
InstanceTemplate instanceTemplate) |
| Modifier and Type | Method and Description |
|---|---|
ClusterSpec |
ClusterActionEvent.getClusterSpec() |
| Modifier and Type | Method and Description |
|---|---|
com.google.common.base.Function<ClusterSpec,org.jclouds.compute.ComputeServiceContext> |
ClusterActionEvent.getCompute() |
| Modifier and Type | Method and Description |
|---|---|
org.jclouds.compute.ComputeServiceContext |
ComputeCache.apply(ClusterSpec arg0) |
org.jclouds.compute.ComputeServiceContext |
DynamicComputeCache.apply(ClusterSpec arg0) |
static void |
FirewallManager.authorizeIngress(org.jclouds.compute.ComputeServiceContext computeServiceContext,
Set<Cluster.Instance> instances,
ClusterSpec clusterSpec,
List<String> cidrs,
int... ports) |
static org.jclouds.blobstore.BlobStoreContext |
BlobStoreContextBuilder.build(ClusterSpec spec) |
protected org.apache.commons.configuration.Configuration |
ClusterActionHandlerSupport.getConfiguration(ClusterSpec clusterSpec,
org.apache.commons.configuration.Configuration defaults)
Returns a composite configuration that is made up from the global
configuration coming from the Whirr core with the service default
properties.
|
protected org.apache.commons.configuration.Configuration |
ClusterActionHandlerSupport.getConfiguration(ClusterSpec clusterSpec,
String defaultsPropertiesFile) |
void |
ComputeCache.invalidate(ClusterSpec arg0) |
| Constructor and Description |
|---|
ClusterActionEvent(String action,
ClusterSpec clusterSpec,
InstanceTemplate instanceTemplate,
Cluster cluster,
com.google.common.base.Function<ClusterSpec,org.jclouds.compute.ComputeServiceContext> getCompute,
FirewallManager firewallManager,
org.apache.velocity.app.VelocityEngine velocityEngine) |
ClusterActionEvent(String action,
ClusterSpec clusterSpec,
InstanceTemplate instanceTemplate,
Cluster cluster,
StatementBuilder statementBuilder,
com.google.common.base.Function<ClusterSpec,org.jclouds.compute.ComputeServiceContext> getCompute,
FirewallManager firewallManager,
org.apache.velocity.app.VelocityEngine velocityEngine) |
FirewallManager(org.jclouds.compute.ComputeServiceContext computeServiceContext,
ClusterSpec clusterSpec,
Cluster cluster) |
| Constructor and Description |
|---|
ClusterActionEvent(String action,
ClusterSpec clusterSpec,
InstanceTemplate instanceTemplate,
Cluster cluster,
com.google.common.base.Function<ClusterSpec,org.jclouds.compute.ComputeServiceContext> getCompute,
FirewallManager firewallManager,
org.apache.velocity.app.VelocityEngine velocityEngine) |
ClusterActionEvent(String action,
ClusterSpec clusterSpec,
InstanceTemplate instanceTemplate,
Cluster cluster,
StatementBuilder statementBuilder,
com.google.common.base.Function<ClusterSpec,org.jclouds.compute.ComputeServiceContext> getCompute,
FirewallManager firewallManager,
org.apache.velocity.app.VelocityEngine velocityEngine) |
| Modifier and Type | Method and Description |
|---|---|
protected org.apache.commons.configuration.Configuration |
DruidClusterActionHandler.getConfiguration(ClusterSpec clusterSpec) |
| Modifier and Type | Method and Description |
|---|---|
static org.jclouds.scriptbuilder.domain.Statement |
ElasticSearchConfigurationBuilder.build(String path,
ClusterSpec spec,
Cluster cluster) |
static org.apache.commons.configuration.Configuration |
ElasticSearchConfigurationBuilder.buildConfig(ClusterSpec spec,
Cluster cluster)
Build a configuration by adding the expected defaults
|
| Modifier and Type | Method and Description |
|---|---|
protected org.apache.commons.configuration.Configuration |
GangliaMonitorClusterActionHandler.getConfiguration(ClusterSpec spec) |
protected org.apache.commons.configuration.Configuration |
GangliaMetadClusterActionHandler.getConfiguration(ClusterSpec spec) |
| Modifier and Type | Method and Description |
|---|---|
static org.jclouds.scriptbuilder.domain.Statement |
HadoopConfigurationBuilder.buildCommon(String path,
ClusterSpec clusterSpec,
Cluster cluster) |
static org.jclouds.scriptbuilder.domain.Statement |
HadoopConfigurationBuilder.buildHadoopEnv(String path,
ClusterSpec clusterSpec,
Cluster cluster) |
static org.jclouds.scriptbuilder.domain.Statement |
HadoopConfigurationBuilder.buildHdfs(String path,
ClusterSpec clusterSpec,
Cluster cluster,
Set<String> dataDirectories) |
static org.jclouds.scriptbuilder.domain.Statement |
HadoopConfigurationBuilder.buildMapReduce(String path,
ClusterSpec clusterSpec,
Cluster cluster,
Set<String> dataDirectories) |
protected org.apache.commons.configuration.Configuration |
HadoopClusterActionHandler.getConfiguration(ClusterSpec clusterSpec)
Returns a composite configuration that is made up from the global
configuration coming from the Whirr core with a hadoop defaults
properties.
|
Map<String,String> |
VolumeManager.getDeviceMappings(ClusterSpec clusterSpec,
Cluster.Instance instance) |
| Constructor and Description |
|---|
HadoopProxy(ClusterSpec clusterSpec,
Cluster cluster) |
| Modifier and Type | Method and Description |
|---|---|
protected org.apache.commons.configuration.Configuration |
HamaClusterActionHandler.getConfiguration(ClusterSpec clusterSpec)
Returns a composite configuration that is made up from the global
configuration coming from the Whirr core with a hama defaults properties.
|
| Modifier and Type | Method and Description |
|---|---|
static org.jclouds.scriptbuilder.domain.Statement |
HBaseConfigurationBuilder.buildHBaseEnv(String path,
ClusterSpec clusterSpec,
Cluster cluster) |
static org.jclouds.scriptbuilder.domain.Statement |
HBaseConfigurationBuilder.buildHBaseSite(String path,
ClusterSpec clusterSpec,
Cluster cluster) |
protected org.apache.commons.configuration.Configuration |
HBaseClusterActionHandler.getConfiguration(ClusterSpec clusterSpec)
Returns a composite configuration that is made up from the global
configuration coming from the Whirr core with a hbase defaults
properties.
|
protected String |
HBaseClusterActionHandler.getMetricsTemplate(ClusterActionEvent event,
ClusterSpec clusterSpec,
Cluster cluster) |
| Modifier and Type | Method and Description |
|---|---|
org.jclouds.scriptbuilder.domain.Statement |
StatementBuilder.build(ClusterSpec clusterSpec) |
org.jclouds.scriptbuilder.domain.Statement |
StatementBuilder.build(ClusterSpec clusterSpec,
Cluster.Instance instance) |
| Modifier and Type | Method and Description |
|---|---|
protected org.apache.commons.configuration.Configuration |
KerberosBaseHandler.getConfiguration(ClusterSpec spec) |
| Modifier and Type | Method and Description |
|---|---|
static org.jclouds.scriptbuilder.domain.Statement |
YarnConfigurationBuilder.build(String path,
ClusterSpec clusterSpec,
Cluster cluster,
String role) |
protected org.apache.commons.configuration.Configuration |
YarnHandler.getConfiguration(ClusterSpec clusterSpec) |
| Modifier and Type | Method and Description |
|---|---|
protected org.apache.commons.configuration.Configuration |
ZooKeeperClusterActionHandler.getConfiguration(ClusterSpec spec) |
| Modifier and Type | Method and Description |
|---|---|
ClusterStateStore |
ClusterStateStoreFactory.create(ClusterSpec spec) |
protected Cluster |
ClusterStateStore.unserialize(ClusterSpec spec,
String content)
Rebuild the
Cluster instance by using the string representation |
| Constructor and Description |
|---|
BlobClusterStateStore(ClusterSpec spec) |
FileClusterStateStore(ClusterSpec spec) |
| Modifier and Type | Method and Description |
|---|---|
static org.jclouds.scriptbuilder.domain.Statement |
TemplateUtils.createFileFromTemplate(String path,
org.apache.velocity.app.VelocityEngine engine,
String templateName,
ClusterSpec clusterSpec,
Cluster cluster) |
static String |
TemplateUtils.processTemplate(org.apache.velocity.app.VelocityEngine engine,
String templateName,
ClusterSpec clusterSpec,
Cluster cluster) |
| Modifier and Type | Method and Description |
|---|---|
static BlobCache |
BlobCache.getInstance(com.google.common.base.Function<ClusterSpec,org.jclouds.compute.ComputeServiceContext> getCompute,
ClusterSpec spec) |
static void |
Utils.printSSHConnectionDetails(PrintStream out,
ClusterSpec clusterSpec,
Cluster cluster,
int maxPrint)
Prints ssh commands that can be used to login into the nodes
|
| Modifier and Type | Method and Description |
|---|---|
static BlobCache |
BlobCache.getInstance(com.google.common.base.Function<ClusterSpec,org.jclouds.compute.ComputeServiceContext> getCompute,
ClusterSpec spec) |
Copyright © 2010–2016 Cloudera. All rights reserved.