| Package | Description |
|---|---|
| org.apache.whirr |
The Whirr client API.
|
| org.apache.whirr.actions |
A collection of
ClusterAction implementations. |
| org.apache.whirr.command | |
| 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.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 |
|---|---|
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) |
static Cluster |
Cluster.empty() |
abstract Cluster |
ClusterAction.execute(ClusterSpec clusterSpec,
Cluster cluster) |
Cluster |
ClusterController.launchCluster(ClusterSpec clusterSpec)
Start the cluster described by
clusterSpec and block until the
cluster is
available. |
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) |
| Modifier and Type | Method and Description |
|---|---|
Cluster |
ClusterController.cleanupCluster(ClusterSpec clusterSpec,
Cluster cluster) |
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) |
void |
ClusterController.destroyCluster(ClusterSpec clusterSpec,
Cluster cluster) |
abstract Cluster |
ClusterAction.execute(ClusterSpec clusterSpec,
Cluster cluster) |
Cluster |
ClusterController.startServices(ClusterSpec clusterSpec,
Cluster cluster) |
Cluster |
ClusterController.startServices(ClusterSpec clusterSpec,
Cluster cluster,
Set<String> targetRoles,
Set<String> targetInstanceIds) |
Cluster |
ClusterController.stopServices(ClusterSpec clusterSpec,
Cluster cluster) |
Cluster |
ClusterController.stopServices(ClusterSpec clusterSpec,
Cluster cluster,
Set<String> targetRoles,
Set<String> targetInstanceIds) |
| Modifier and Type | Method and Description |
|---|---|
Cluster |
ScriptBasedClusterAction.execute(ClusterSpec clusterSpec,
Cluster cluster) |
| Modifier and Type | Method and Description |
|---|---|
Cluster |
ScriptBasedClusterAction.execute(ClusterSpec clusterSpec,
Cluster cluster) |
| Modifier and Type | Method and Description |
|---|---|
protected Cluster |
AbstractClusterCommand.getCluster(ClusterSpec clusterSpec,
ClusterController controller)
Get the cluster instance together with NodeMetadata (through API calls)
|
| Modifier and Type | Method and Description |
|---|---|
Cluster |
ClusterActionEvent.getCluster() |
| Modifier and Type | Method and Description |
|---|---|
void |
ClusterActionEvent.setCluster(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) |
FirewallManager(org.jclouds.compute.ComputeServiceContext computeServiceContext,
ClusterSpec clusterSpec,
Cluster cluster) |
| Modifier and Type | Method and Description |
|---|---|
static String |
DruidCluster.getMySQLPublicAddress(Cluster cluster)
Returns the public address of the MySQL node.
|
| 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 |
|---|---|
static String |
GangliaCluster.getHosts(Cluster cluster) |
| 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) |
static InetAddress |
HadoopCluster.getJobTrackerPrivateAddress(Cluster cluster) |
static InetAddress |
HadoopCluster.getJobTrackerPublicAddress(Cluster cluster) |
static InetAddress |
HadoopCluster.getNamenodePrivateAddress(Cluster cluster) |
static InetAddress |
HadoopCluster.getNamenodePublicAddress(Cluster cluster) |
| Constructor and Description |
|---|
HadoopProxy(ClusterSpec clusterSpec,
Cluster cluster) |
| Modifier and Type | Method and Description |
|---|---|
static InetAddress |
HamaCluster.getMasterPublicAddress(Cluster cluster) |
| 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) |
static InetAddress |
HBaseCluster.getMasterPublicAddress(Cluster cluster) |
protected String |
HBaseClusterActionHandler.getMetricsTemplate(ClusterActionEvent event,
ClusterSpec clusterSpec,
Cluster cluster) |
| Modifier and Type | Method and Description |
|---|---|
static org.jclouds.scriptbuilder.domain.Statement |
YarnConfigurationBuilder.build(String path,
ClusterSpec clusterSpec,
Cluster cluster,
String role) |
| Modifier and Type | Method and Description |
|---|---|
static String |
ZooKeeperCluster.getHosts(Cluster cluster) |
static String |
ZooKeeperCluster.getHosts(Cluster cluster,
boolean internalHosts) |
| Modifier and Type | Method and Description |
|---|---|
Cluster |
MemoryClusterStateStore.load() |
Cluster |
FileClusterStateStore.load() |
Cluster |
BlobClusterStateStore.load() |
abstract Cluster |
ClusterStateStore.load()
Deserializes cluster state from storage.
|
Cluster |
ClusterStateStore.tryLoadOrEmpty()
Try to load the cluster state or return an empty instance
|
protected Cluster |
ClusterStateStore.unserialize(ClusterSpec spec,
String content)
Rebuild the
Cluster instance by using the string representation |
| Modifier and Type | Method and Description |
|---|---|
void |
MemoryClusterStateStore.save(Cluster cluster) |
void |
FileClusterStateStore.save(Cluster cluster) |
void |
BlobClusterStateStore.save(Cluster cluster) |
abstract void |
ClusterStateStore.save(Cluster cluster)
Saves cluster state to storage.
|
protected String |
ClusterStateStore.serialize(Cluster cluster)
Create parser friendly string representation for a
Cluster |
| 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 void |
Utils.printSSHConnectionDetails(PrintStream out,
ClusterSpec clusterSpec,
Cluster cluster,
int maxPrint)
Prints ssh commands that can be used to login into the nodes
|
Copyright © 2010–2016 Cloudera. All rights reserved.