org.apache.cassandra.config.DatabaseDescriptor.getClusterName()方法的使用及代码示例

本文整理了Java中org.apache.cassandra.config.DatabaseDescriptor.getClusterName()方法的一些代码示例，展示了DatabaseDescriptor.getClusterName()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。DatabaseDescriptor.getClusterName()方法的具体详情如下：
包路径：org.apache.cassandra.config.DatabaseDescriptor
类名称：DatabaseDescriptor
方法名：getClusterName

DatabaseDescriptor.getClusterName介绍

暂无

代码示例

代码示例来源：origin: jsevellec/cassandra-unit

/** Returns the name of the cluster */
public String getClusterName()
{
return DatabaseDescriptor.getClusterName();
}

代码示例来源：origin: jsevellec/cassandra-unit

/**
* Get the embedded cassandra cluster name
*
* @return the cluster name
*/
public static String getClusterName() {
return DatabaseDescriptor.getClusterName();
}

代码示例来源：origin: com.strapdata.cassandra/cassandra-all

/** Returns the name of the cluster */
public String getClusterName()
{
return DatabaseDescriptor.getClusterName();
}

代码示例来源：origin: org.cassandraunit/cassandra-unit

/**
* Get the embedded cassandra cluster name
*
* @return the cluster name
*/
public static String getClusterName() {
return DatabaseDescriptor.getClusterName();
}

代码示例来源：origin: org.apache.cassandra/cassandra-all

/** Returns the name of the cluster */
public String getClusterName()
{
return DatabaseDescriptor.getClusterName();
}

代码示例来源：origin: jsevellec/cassandra-unit

/**
* Get the embedded cassandra cluster name
*
* @return the cluster name
*/
public static String getClusterName() {
return DatabaseDescriptor.getClusterName();
}

代码示例来源：origin: org.apache.cassandra/cassandra-all

public String describe_cluster_name() throws TException
{
return DatabaseDescriptor.getClusterName();
}

代码示例来源：origin: com.facebook.presto.cassandra/cassandra-server

/** Returns the name of the cluster */
public String getClusterName()
{
return DatabaseDescriptor.getClusterName();
}

代码示例来源：origin: io.smartcat/cassandra-diagnostics-embedded-cassandra

/**
* Get the embedded cassandra cluster name.
*
* @return the cluster name
*/
public static String getClusterName() {
return DatabaseDescriptor.getClusterName();
}

代码示例来源：origin: com.strapdata.cassandra/cassandra-all

public String describe_cluster_name() throws TException
{
return DatabaseDescriptor.getClusterName();
}

代码示例来源：origin: smartcat-labs/cassandra-diagnostics

/**
* Get the embedded cassandra cluster name.
*
* @return the cluster name
*/
public static String getClusterName() {
return DatabaseDescriptor.getClusterName();
}

代码示例来源：origin: com.facebook.presto.cassandra/cassandra-server

public String describe_cluster_name() throws TException
{
return DatabaseDescriptor.getClusterName();
}

代码示例来源：origin: com.strapdata.elasticsearch/elasticsearch

public static String getElasticsearchClusterName(Settings settings) {
String clusterName = DatabaseDescriptor.getClusterName();
String datacenterGroup = settings.get(ClusterService.SETTING_CLUSTER_DATACENTER_GROUP);
if (datacenterGroup != null) {
clusterName = DatabaseDescriptor.getClusterName() + "@" + datacenterGroup.trim();
}
return clusterName;
}

代码示例来源：origin: com.strapdata.elasticsearch/elasticsearch

Void insertFirstMetaRow(final MetaData metadata, final String metaDataString) {
try {
logger.info(insertMetadataQuery);
process(ConsistencyLevel.LOCAL_ONE, ClientState.forInternalCalls(), insertMetadataQuery,
DatabaseDescriptor.getClusterName(), UUID.fromString(StorageService.instance.getLocalHostId()), metadata.version(), metaDataString);
} catch (Exception e) {
logger.error((Supplier) () -> new ParameterizedMessage("Failed insert first row into table {}.{}", elasticAdminKeyspaceName, ELASTIC_ADMIN_METADATA_TABLE), e);
throw e;
}
return null;
}

代码示例来源：origin: com.strapdata.elasticsearch/elasticsearch

public MetaData readInternalMetaDataAsRow() throws NoPersistedMetaDataException {
try {
UntypedResultSet rs = QueryProcessor.executeInternal(selectMetadataQuery, DatabaseDescriptor.getClusterName());
if (rs != null && !rs.isEmpty()) {
Row row = rs.one();
if (row.has("metadata"))
return parseMetaDataString(row.getString("metadata"));
}
} catch (Exception e) {
logger.warn("Cannot read metadata locally",e);
}
return null;
}

代码示例来源：origin: com.strapdata.elasticsearch/elasticsearch

public Long readMetaDataVersion(ConsistencyLevel cl) throws NoPersistedMetaDataException {
try {
UntypedResultSet rs = process(cl, ClientState.forInternalCalls(), selectVersionMetadataQuery, DatabaseDescriptor.getClusterName());
if (rs != null && !rs.isEmpty()) {
Row row = rs.one();
if (row.has("version"))
return row.getLong("version");
}
} catch (Exception e) {
logger.warn("unexpected error", e);
}
return -1L;
}
public static String getElasticsearchClusterName(Settings settings) {

代码示例来源：origin: com.strapdata.elasticsearch/elasticsearch

public MetaData readMetaDataAsRow(ConsistencyLevel cl) throws NoPersistedMetaDataException {
try {
UntypedResultSet rs = process(cl, ClientState.forInternalCalls(), selectMetadataQuery, DatabaseDescriptor.getClusterName());
if (rs != null && !rs.isEmpty()) {
Row row = rs.one();
if (row.has("metadata"))
return parseMetaDataString(row.getString("metadata"));
}
} catch (UnavailableException e) {
logger.warn("Cannot read metadata with cOnsistency="+cl,e);
return null;
} catch (KeyspaceNotDefinedException e) {
logger.warn("Keyspace {} not yet defined", ELASTIC_ADMIN_KEYSPACE);
return null;
} catch (Exception e) {
throw new NoPersistedMetaDataException("Unexpected error",e);
}
throw new NoPersistedMetaDataException("Unexpected error");
}

代码示例来源：origin: jsevellec/cassandra-unit

executeOnceInternal(String.format(req, LOCAL),
LOCAL,
DatabaseDescriptor.getClusterName(),
FBUtilities.getReleaseVersionString(),
QueryProcessor.CQL_VERSION.toString(),

代码示例来源：origin: org.apache.cassandra/cassandra-all

executeOnceInternal(String.format(req, LOCAL),
LOCAL,
DatabaseDescriptor.getClusterName(),
FBUtilities.getReleaseVersionString(),
QueryProcessor.CQL_VERSION.toString(),

代码示例来源：origin: com.strapdata.elasticsearch/elasticsearch

public void persistMetaData(MetaData oldMetaData, MetaData newMetaData, String source) throws IOException, InvalidRequestException, RequestExecutionException, RequestValidationException {
if (!newMetaData.clusterUUID().equals(localNode().getId())) {
logger.error("should not push metadata updated from another node {}/{}", newMetaData.clusterUUID(), newMetaData.version());
return;
}
if (newMetaData.clusterUUID().equals(state().metaData().clusterUUID()) && newMetaData.version() logger.warn("don't push obsolete metadata uuid={} version {} <{}", newMetaData.clusterUUID(), newMetaData.version(), state().metaData().version());
return;
}
String metaDataString = MetaData.Builder.toXContent(newMetaData, MetaData.CASSANDRA_FORMAT_PARAMS);
UUID owner = UUID.fromString(localNode().getId());
boolean applied = processWriteConditional(
this.metadataWriteCL,
this.metadataSerialCL,
ClientState.forInternalCalls(),
updateMetaDataQuery,
new Object[] { owner, newMetaData.version(), metaDataString, DatabaseDescriptor.getClusterName(), newMetaData.version() });
if (applied) {
logger.debug("PAXOS Succefully update metadata source={} newMetaData={} in cluster {}", source, metaDataString, DatabaseDescriptor.getClusterName());
writeMetaDataAsComment(metaDataString, newMetaData.version());
return;
} else {
logger.warn("PAXOS Failed to update metadata oldMetadata={}/{} currentMetaData={}/{} in cluster {}",
oldMetaData.clusterUUID(), oldMetaData.version(), localNode().getId(), newMetaData.version(), DatabaseDescriptor.getClusterName());
throw new ConcurrentMetaDataUpdateException(owner, newMetaData.version());
}
}