CassandraNodeImpl (Apache Brooklyn)

java.lang.Object
- brooklyn.basic.AbstractBrooklynObject
- - brooklyn.entity.basic.AbstractEntity
  - - brooklyn.entity.basic.SoftwareProcessImpl
    - - brooklyn.entity.nosql.cassandra.CassandraNodeImpl

All Implemented Interfaces:

BrooklynObject, BrooklynObjectInternal, EntityInternal, EntityLocal, SoftwareProcess, DatastoreMixins.CanExecuteScript, DatastoreMixins.CanGiveCreationScript, DatastoreMixins.DatastoreCommon, DatastoreMixins.HasDatastoreUrl, DriverDependentEntity, Entity, UsesJava, UsesJavaMXBeans, UsesJmx, CassandraNode, Rebindable, Configurable, Identifiable, Startable
```
public class CassandraNodeImpl
extends SoftwareProcessImpl
implements CassandraNode
```
Implementation of CassandraNode.

Nested Class Summary
- Nested classes/interfaces inherited from interface brooklyn.entity.basic.SoftwareProcess
  SoftwareProcess.ChildStartableMode, SoftwareProcess.RestartSoftwareParameters, SoftwareProcess.StopSoftwareParameters
- Nested classes/interfaces inherited from interface brooklyn.basic.BrooklynObject
  BrooklynObject.TagSupport
- Nested classes/interfaces inherited from interface brooklyn.entity.trait.Configurable
  Configurable.ConfigurationSupport
- Nested classes/interfaces inherited from interface brooklyn.entity.trait.Startable
  Startable.RestartEffectorBody, Startable.StartEffectorBody, Startable.StopEffectorBody
- Nested classes/interfaces inherited from interface brooklyn.entity.java.UsesJmx
  UsesJmx.JmxAgentModes
- Nested classes/interfaces inherited from interface brooklyn.entity.basic.EntityInternal
  EntityInternal.FeedSupport
- Nested classes/interfaces inherited from interface brooklyn.basic.BrooklynObjectInternal
  BrooklynObjectInternal.ConfigurationSupportInternal

Field Summary
- Fields inherited from class brooklyn.entity.basic.AbstractEntity
  CHILD_ADDED, CHILD_REMOVED, EFFECTOR_ADDED, EFFECTOR_CHANGED, EFFECTOR_REMOVED, LOCATION_ADDED, LOCATION_REMOVED, POLICY_ADDED, POLICY_REMOVED, SENSOR_ADDED, SENSOR_REMOVED
- Fields inherited from interface brooklyn.entity.nosql.cassandra.CassandraNode
  BROADCAST_ADDRESS_SENSOR, CASSANDRA_CONFIG_FILE_NAME, CASSANDRA_CONFIG_TEMPLATE_URL, CASSANDRA_RACKDC_CONFIG_FILE_NAME, CASSANDRA_RACKDC_CONFIG_TEMPLATE_URL, CLUSTER_NAME, CUSTOM_SNITCH_JAR_URL, DATACENTER_NAME, DOWNLOAD_URL, ENDPOINT_SNITCH_NAME, EXECUTE_SCRIPT, GOSSIP_PORT, INITIAL_SEEDS, JMX_AGENT_MODE, LISTEN_ADDRESS_SENSOR, LIVE_NODE_COUNT, MIRROR_URL, NATIVE_TRANSPORT_PORT, NUM_TOKENS_PER_NODE, PEERS, RACK_NAME, READ_ACTIVE, READ_COMPLETED, READ_PENDING, READS_PER_SECOND_IN_WINDOW, READS_PER_SECOND_LAST, RMI_REGISTRY_PORT, RPC_ADDRESS_SENSOR, SERVICE_UP_JMX, SSL_GOSSIP_PORT, START_TIMEOUT, SUGGESTED_VERSION, TGZ_URL, THRIFT_PORT, THRIFT_PORT_LATENCY, THRIFT_PORT_LATENCY_IN_WINDOW, TOKEN, TOKENS, WRITE_ACTIVE, WRITE_COMPLETED, WRITE_PENDING, WRITES_PER_SECOND_IN_WINDOW, WRITES_PER_SECOND_LAST
- Fields inherited from interface brooklyn.entity.database.DatastoreMixins.HasDatastoreUrl
  DATASTORE_URL
- Fields inherited from interface brooklyn.entity.database.DatastoreMixins.CanGiveCreationScript
  CREATION_SCRIPT_CONTENTS, CREATION_SCRIPT_URL
- Fields inherited from interface brooklyn.entity.basic.SoftwareProcess
  ADDRESS, CHILDREN_STARTABLE_MODE, CUSTOMIZE_LATCH, DOWNLOAD_ADDON_URLS, ENTITY_STARTED, EXPANDED_INSTALL_DIR, HOSTNAME, INSTALL_DIR, INSTALL_FILES, INSTALL_LATCH, INSTALL_RESOURCES_LATCH, INSTALL_TEMPLATES, INSTALL_UNIQUE_LABEL, LAUNCH_LATCH, MAXIMUM_REBIND_SENSOR_CONNECT_DELAY, PID_FILE, POST_INSTALL_COMMAND, POST_LAUNCH_COMMAND, PRE_INSTALL_COMMAND, PRE_INSTALL_FILES, PRE_INSTALL_TEMPLATES, PRE_LAUNCH_COMMAND, PROVISIONING_LOCATION, PROVISIONING_PROPERTIES, REQUIRED_OPEN_LOGIN_PORTS, RUN_DIR, RUNTIME_FILES, RUNTIME_RESOURCES_LATCH, RUNTIME_TEMPLATES, SERVICE_PROCESS_IS_RUNNING, SERVICE_STATE_ACTUAL, SERVICE_STATE_EXPECTED, SETUP_LATCH, SHELL_ENVIRONMENT, SKIP_ENTITY_START_IF_RUNNING, SKIP_INSTALLATION, START_LATCH, SUBNET_ADDRESS, SUBNET_HOSTNAME, SUGGESTED_INSTALL_DIR, SUGGESTED_RUN_DIR
- Fields inherited from interface brooklyn.entity.trait.Startable
  RESTART, SERVICE_UP, START, STOP
- Fields inherited from interface brooklyn.entity.java.UsesJmx
  DEFAULT_JMX_PORT, JMX_AGENT_LOCAL_PATH, JMX_CONTEXT, JMX_PASSWORD, JMX_PORT, JMX_PORT_LEGACY, JMX_SSL_ACCESS_CERT, JMX_SSL_ACCESS_KEY, JMX_SSL_ENABLED, JMX_URL, JMX_USER, USE_JMX
- Fields inherited from interface brooklyn.entity.java.UsesJava
  CHECK_JAVA_HOSTNAME_BUG, JAVA_OPTS, JAVA_SYSPROPS, JAVA_VERSION_REQUIRED
- Fields inherited from interface brooklyn.entity.java.UsesJavaMXBeans
  AVAILABLE_PROCESSORS, COMMITTED_HEAP_MEMORY, CURRENT_THREAD_COUNT, FREE_PHYSICAL_MEMORY_SIZE, GARBAGE_COLLECTION_TIME, INIT_HEAP_MEMORY, MAX_HEAP_MEMORY, MXBEAN_STATS_ENABLED, NON_HEAP_MEMORY_USAGE, PEAK_THREAD_COUNT, PROCESS_CPU_TIME, PROCESS_CPU_TIME_FRACTION_IN_WINDOW, PROCESS_CPU_TIME_FRACTION_LAST, START_TIME, SYSTEM_LOAD_AVERAGE, TOTAL_PHYSICAL_MEMORY_SIZE, UP_TIME, USED_HEAP_MEMORY

Constructor Summary

Constructors
Constructor and Description

CassandraNodeImpl()

Constructors
Constructor and Description
`CassandraNodeImpl()`

Method Summary

Methods
Modifier and Type	Method and Description
`void`	`disconnectSensors()` For disconnecting from the running app.
`java.lang.String`	`executeScript(java.lang.String commands)`
`java.lang.String`	`getBroadcastAddress()`
`java.lang.String`	`getCassandraConfigTemplateUrl()`
`java.lang.String`	`getClusterName()`
`java.lang.String`	`getDatacenterName()`
`CassandraNodeDriver`	`getDriver()`
`java.lang.Class<? extends CassandraNodeDriver>`	`getDriverInterface()`
`java.lang.Integer`	`getGossipPort()`
`java.lang.String`	`getListenAddress()`
`java.lang.String`	`getMajorMinorVersion()`
`java.lang.Integer`	`getNativeTransportPort()`
`int`	`getNumTokensPerNode()`
`java.lang.String`	`getPrivateIp()` not always the private IP, if public IP has been insisted on for broadcast, e.g.
`java.lang.String`	`getPublicIp()`
`java.lang.String`	`getRackName()`
`java.lang.String`	`getRpcAddress()`
`java.lang.String`	`getSeeds()`
`java.lang.Integer`	`getSslGossipPort()`
`java.lang.Integer`	`getThriftPort()`
`java.math.BigInteger`	`getToken()` Deprecated.
`java.lang.String`	`getTokenAsString()` Deprecated.
`java.util.Set<java.math.BigInteger>`	`getTokens()`
`java.lang.String`	`getTokensAsString()` string value of comma-separated tokens; or blank if none
`void`	`init()` Default entity initialization, just calls `AbstractEntity.initEnrichers()`.
`void`	`setToken(java.lang.String token)`

Methods inherited from class brooklyn.entity.basic.SoftwareProcessImpl
checkModifiable, getLocalHostname, onManagementStarted, onManagementStarting, rebind, restart, start, stop, waitForEntityStart, waitForServiceUp, waitForServiceUp, waitForServiceUp, waitForServiceUp

Methods inherited from class brooklyn.entity.basic.AbstractEntity
addChild, addChild, addEnricher, addEnricher, addFeed, addGroup, addLocations, addPolicy, addPolicy, addTag, clearLocations, clearParent, config, configure, configure, configure, configure, configure, containsTag, destroy, emit, emitInternal, equals, feeds, firstLocation, getAllAttributes, getAllConfig, getAllConfigBag, getApplication, getApplicationId, getAttribute, getAttributeByNameParts, getChildren, getConfig, getConfig, getConfig, getConfig, getConfigMap, getConfigRaw, getConfigRaw, getCreationTime, getDisplayName, getEffector, getEnrichers, getEntityType, getExecutionContext, getFeedSupport, getGroups, getIconUrl, getLocalConfigBag, getLocations, getManagementContext, getManagementSupport, getMutableEntityType, getParent, getPolicies, getProxy, getProxyIfAvailable, getRebindSupport, getSubscriptionContext, getTags, hashCode, invalidateReferences, invoke, invoke, invoke, modifyAttribute, onManagementBecomingMaster, onManagementNoLongerMaster, onManagementStopped, refreshInheritedConfig, removeAllEnrichers, removeAllPolicies, removeAttribute, removeChild, removeEnricher, removeGroup, removeLocations, removePolicy, removeTag, requestPersist, resetProxy, setAttribute, setAttribute, setAttributeWithoutPublishing, setConfig, setConfig, setConfig, setConfig, setConfig, setConfig, setConfigEvenIfOwned, setConfigEvenIfOwned, setDisplayName, setManagementContext, setParent, setProxy, subscribe, subscribeToChildren, subscribeToMembers, toMetadataRecord, toString, unsubscribe, unsubscribe

Methods inherited from class brooklyn.basic.AbstractBrooklynObject
getCatalogItemId, getId, getTagSupport, setCatalogItemId, tags

Methods inherited from class java.lang.Object
getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface brooklyn.entity.Entity
addChild, addChild, addEnricher, addEnricher, addFeed, addGroup, addPolicy, addPolicy, addTag, clearParent, containsTag, getApplication, getApplicationId, getAttribute, getChildren, getConfig, getConfig, getConfigRaw, getConfigRaw, getCreationTime, getDisplayName, getEnrichers, getEntityType, getGroups, getIconUrl, getId, getLocations, getParent, getPolicies, getTags, invoke, removeChild, removeEnricher, removeGroup, removePolicy, removeTag, setParent

Methods inherited from interface brooklyn.basic.BrooklynObject
getCatalogItemId, getTagSupport, tags

Methods inherited from interface brooklyn.entity.trait.Configurable
config, setConfig

Methods inherited from interface brooklyn.entity.trait.Startable
restart, start, stop

Methods inherited from interface brooklyn.basic.BrooklynObjectInternal
setCatalogItemId

- Constructor Detail
  - CassandraNodeImpl
```
public CassandraNodeImpl()
```
- Method Detail
  - init
```
public void init()
```
    Description copied from class: AbstractEntity
    
    Default entity initialization, just calls AbstractEntity.initEnrichers().
    
    Overrides:
    
    init in class SoftwareProcessImpl
  - getMajorMinorVersion
```
public java.lang.String getMajorMinorVersion()
```
    Specified by:
    
    getMajorMinorVersion in interface CassandraNode
  - getCassandraConfigTemplateUrl
```
public java.lang.String getCassandraConfigTemplateUrl()
```
  - getGossipPort
```
public java.lang.Integer getGossipPort()
```
    Specified by:
    
    getGossipPort in interface CassandraNode
  - getSslGossipPort
```
public java.lang.Integer getSslGossipPort()
```
    Specified by:
    
    getSslGossipPort in interface CassandraNode
  - getThriftPort
```
public java.lang.Integer getThriftPort()
```
    Specified by:
    
    getThriftPort in interface CassandraNode
  - getNativeTransportPort
```
public java.lang.Integer getNativeTransportPort()
```
    Specified by:
    
    getNativeTransportPort in interface CassandraNode
  - getClusterName
```
public java.lang.String getClusterName()
```
    Specified by:
    
    getClusterName in interface CassandraNode
  - getNumTokensPerNode
```
public int getNumTokensPerNode()
```
    Specified by:
    
    getNumTokensPerNode in interface CassandraNode
  - getToken
```
@Deprecated
public java.math.BigInteger getToken()
```
    Deprecated.
    
    Description copied from interface: CassandraNode
    
    In range 0 to (2^127)-1; or null if not yet set or known. Returns the first token if more than one token.
    
    Specified by:
    
    getToken in interface CassandraNode
  - getTokens
```
public java.util.Set<java.math.BigInteger> getTokens()
```
    Specified by:
    
    getTokens in interface CassandraNode
  - getTokenAsString
```
@Deprecated
public java.lang.String getTokenAsString()
```
    Deprecated.
    
    Description copied from interface: CassandraNode
    
    string value of token (with no commas, which freemarker introduces!) or blank if none
    
    Specified by:
    
    getTokenAsString in interface CassandraNode
  - getTokensAsString
```
public java.lang.String getTokensAsString()
```
    Description copied from interface: CassandraNode
    
    string value of comma-separated tokens; or blank if none
    
    Specified by:
    
    getTokensAsString in interface CassandraNode
  - getListenAddress
```
public java.lang.String getListenAddress()
```
    Specified by:
    
    getListenAddress in interface CassandraNode
  - getBroadcastAddress
```
public java.lang.String getBroadcastAddress()
```
    Specified by:
    
    getBroadcastAddress in interface CassandraNode
  - getPrivateIp
```
public java.lang.String getPrivateIp()
```
    not always the private IP, if public IP has been insisted on for broadcast, e.g. setting up a rack topology
    
    Specified by:
    
    getPrivateIp in interface CassandraNode
  - getPublicIp
```
public java.lang.String getPublicIp()
```
    Specified by:
    
    getPublicIp in interface CassandraNode
  - getRpcAddress
```
public java.lang.String getRpcAddress()
```
    Specified by:
    
    getRpcAddress in interface CassandraNode
  - getSeeds
```
public java.lang.String getSeeds()
```
    Specified by:
    
    getSeeds in interface CassandraNode
  - getDatacenterName
```
public java.lang.String getDatacenterName()
```
  - getRackName
```
public java.lang.String getRackName()
```
  - getDriverInterface
```
public java.lang.Class<? extends CassandraNodeDriver> getDriverInterface()
```
    Specified by:
    
    getDriverInterface in interface DriverDependentEntity
  - getDriver
```
public CassandraNodeDriver getDriver()
```
    Specified by:
    
    getDriver in interface DriverDependentEntity
    
    Overrides:
    
    getDriver in class SoftwareProcessImpl
  - disconnectSensors
```
public void disconnectSensors()
```
    Description copied from class: SoftwareProcessImpl
    
    For disconnecting from the running app. Will be called on stop.
  - setToken
```
public void setToken(java.lang.String token)
```
    Specified by:
    
    setToken in interface CassandraNode
  - executeScript
```
public java.lang.String executeScript(java.lang.String commands)
```
    Specified by:
    
    executeScript in interface CassandraNode

Class CassandraNodeImpl

Nested Class Summary

Nested classes/interfaces inherited from interface brooklyn.entity.basic.SoftwareProcess

Nested classes/interfaces inherited from interface brooklyn.basic.BrooklynObject

Nested classes/interfaces inherited from interface brooklyn.entity.trait.Configurable

Nested classes/interfaces inherited from interface brooklyn.entity.trait.Startable

Nested classes/interfaces inherited from interface brooklyn.entity.java.UsesJmx

Nested classes/interfaces inherited from interface brooklyn.entity.basic.EntityInternal

Nested classes/interfaces inherited from interface brooklyn.basic.BrooklynObjectInternal

Field Summary

Fields inherited from class brooklyn.entity.basic.AbstractEntity

Fields inherited from interface brooklyn.entity.nosql.cassandra.CassandraNode

Fields inherited from interface brooklyn.entity.database.DatastoreMixins.HasDatastoreUrl

Fields inherited from interface brooklyn.entity.database.DatastoreMixins.CanGiveCreationScript

Fields inherited from interface brooklyn.entity.basic.SoftwareProcess

Fields inherited from interface brooklyn.entity.trait.Startable

Fields inherited from interface brooklyn.entity.java.UsesJmx

Fields inherited from interface brooklyn.entity.java.UsesJava

Fields inherited from interface brooklyn.entity.java.UsesJavaMXBeans

Constructor Summary

Method Summary

Methods inherited from class brooklyn.entity.basic.SoftwareProcessImpl

Methods inherited from class brooklyn.entity.basic.AbstractEntity

Methods inherited from class brooklyn.basic.AbstractBrooklynObject

Methods inherited from class java.lang.Object

Methods inherited from interface brooklyn.entity.Entity

Methods inherited from interface brooklyn.basic.BrooklynObject

Methods inherited from interface brooklyn.entity.trait.Configurable

Methods inherited from interface brooklyn.entity.trait.Startable

Methods inherited from interface brooklyn.basic.BrooklynObjectInternal

Constructor Detail

CassandraNodeImpl

Method Detail

init

getMajorMinorVersion

getCassandraConfigTemplateUrl

getGossipPort

getSslGossipPort

getThriftPort

getNativeTransportPort

getClusterName

getNumTokensPerNode

getToken

getTokens

getTokenAsString

getTokensAsString

getListenAddress

getBroadcastAddress

getPrivateIp

getPublicIp

getRpcAddress

getSeeds

getDatacenterName

getRackName

getDriverInterface

getDriver

disconnectSensors

setToken

executeScript