com.datastax.driver.core.Metadata.newToken()方法的使用及代码示例

x33g5p2x  于2022-01-24 转载在 其他  
字(9.4k)|赞(0)|评价(0)|浏览(108)

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

Metadata.newToken介绍

[英]Builds a new Token from its string representation, according to the partitioner reported by the Cassandra nodes.
[中]根据Cassandra节点报告的分区器，从其字符串表示构建一个新的令牌。

代码示例

代码示例来源：origin: hugegraph/hugegraph

private TokenRange rangeToTokenRange(Range<Token> range) {
  TokenFactory tokenFactory = this.partitioner.getTokenFactory();
  Metadata metadata = this.session.metadata();
  return metadata.newTokenRange(
          metadata.newToken(tokenFactory.toString(range.left)),
          metadata.newToken(tokenFactory.toString(range.right)));
}

代码示例来源：origin: com.datastax.cassandra/cassandra-driver-core

@Test(groups = "short")
public void should_create_token_from_partition_key() {
 Metadata metadata = cluster().getMetadata();
 Row row = session().execute("SELECT token(i) FROM foo WHERE i = 1").one();
 Token expected = row.getToken(0);
 ProtocolVersion protocolVersion =
   cluster().getConfiguration().getProtocolOptions().getProtocolVersion();
 assertThat(metadata.newToken(TypeCodec.cint().serialize(1, protocolVersion)))
   .isEqualTo(expected);
}

代码示例来源：origin: com.datastax.cassandra/cassandra-driver-core

@Test(groups = "short")
public void should_expose_token_and_range_creation_methods() {
 Metadata metadata = cluster().getMetadata();
 // Pick a random range
 TokenRange range = metadata.getTokenRanges().iterator().next();
 Token start = metadata.newToken(range.getStart().toString());
 Token end = metadata.newToken(range.getEnd().toString());
 assertThat(metadata.newTokenRange(start, end)).isEqualTo(range);
}

代码示例来源：origin: com.datastax.cassandra/cassandra-driver-core

/**
 * Ensures that calling {@link Metadata#newToken(String)} on a Cluster that has schema metadata
 * disabled will throw a {@link IllegalStateException}.
 *
 * @jira_ticket JAVA-858
 * @since 2.0.11
 */
@Test(groups = "short", expectedExceptions = IllegalStateException.class)
public void should_throw_illegal_state_exception_on_newToken_with_metadata_disabled() {
 Cluster cluster =
   Cluster.builder()
     .addContactPoints(getContactPoints())
     .withPort(ccm().getBinaryPort())
     .withQueryOptions(nonDebouncingQueryOptions().setMetadataEnabled(false))
     .build();
 try {
  cluster.init();
  cluster.getMetadata().newToken("0x00");
 } finally {
  cluster.close();
 }
}

代码示例来源：origin: com.datastax.cassandra/cassandra-driver-core

Token token1 = schemaDisabledCluster.getMetadata().newToken("0");
Token token2 = schemaDisabledCluster.getMetadata().newToken("111111");
assertThat(token1).isNotNull();
assertThat(token2).isNotNull();

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

public TokenRange getRange(ByteBuffer key)
{
  Token t = partitioner.getToken(key);
  com.datastax.driver.core.Token driverToken = metadata.newToken(partitioner.getTokenFactory().toString(t));
  for (TokenRange range : rangeMap.keySet())
  {
    if (range.contains(driverToken))
    {
      return range;
    }
  }
  throw new RuntimeException("Invalid token information returned by describe_ring: " + rangeMap);
}

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

private TokenRange rangeToTokenRange(Metadata metadata, Range<Token> range)
{
  return metadata.newTokenRange(metadata.newToken(partitioner.getTokenFactory().toString(range.left)),
      metadata.newToken(partitioner.getTokenFactory().toString(range.right)));
}

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

public TokenRange getRange(ByteBuffer key)
{
  Token t = partitioner.getToken(key);
  com.datastax.driver.core.Token driverToken = metadata.newToken(partitioner.getTokenFactory().toString(t));
  for (TokenRange range : rangeMap.keySet())
  {
    if (range.contains(driverToken))
    {
      return range;
    }
  }
  throw new RuntimeException("Invalid token information returned by describe_ring: " + rangeMap);
}

代码示例来源：origin: com.baidu.hugegraph/hugegraph-cassandra

private TokenRange rangeToTokenRange(Range<Token> range) {
  TokenFactory tokenFactory = this.partitioner.getTokenFactory();
  Metadata metadata = this.session.metadata();
  return metadata.newTokenRange(
          metadata.newToken(tokenFactory.toString(range.left)),
          metadata.newToken(tokenFactory.toString(range.right)));
}

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

public TokenRange getRange(ByteBuffer key)
{
  Token t = partitioner.getToken(key);
  com.datastax.driver.core.Token driverToken = metadata.newToken(partitioner.getTokenFactory().toString(t));
  for (TokenRange range : rangeMap.keySet())
  {
    if (range.contains(driverToken))
    {
      return range;
    }
  }
  throw new RuntimeException("Invalid token information returned by describe_ring: " + rangeMap);
}

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

private TokenRange rangeToTokenRange(Metadata metadata, Range<Token> range)
{
  return metadata.newTokenRange(metadata.newToken(partitioner.getTokenFactory().toString(range.left)),
      metadata.newToken(partitioner.getTokenFactory().toString(range.right)));
}

代码示例来源：origin: hawkular/hawkular-metrics

private Observable.Transformer<BoundStatement, Integer> applyMicroBatching() {
  return tObservable -> tObservable
      .groupBy(b -> {
        ByteBuffer routingKey = b.getRoutingKey(ProtocolVersion.NEWEST_SUPPORTED,
            codecRegistry);
        Token token = metadata.newToken(routingKey);
        for (TokenRange tokenRange : session.getCluster().getMetadata().getTokenRanges()) {
          if (tokenRange.contains(token)) {
            return tokenRange;
          }
        }
        log.warn("Unable to find any Cassandra node to insert token " + token.toString());
        return session.getCluster().getMetadata().getTokenRanges().iterator().next();
      })
      .flatMap(g -> g.compose(new BoundBatchStatementTransformer()))
      .flatMap(batch -> rxSession
          .execute(batch)
          .compose(applyInsertRetryPolicy())
          .map(resultSet -> batch.size())
      );
}

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

private TokenRange rangeToTokenRange(Metadata metadata, Range<Token> range)
{
  return metadata.newTokenRange(metadata.newToken(partitioner.getTokenFactory().toString(range.left)),
      metadata.newToken(partitioner.getTokenFactory().toString(range.right)));
}

代码示例来源：origin: org.hawkular.metrics/hawkular-metrics-core-service

private Observable.Transformer<BoundStatement, Integer> applyMicroBatching() {
  return tObservable -> tObservable
      .groupBy(b -> {
        ByteBuffer routingKey = b.getRoutingKey(ProtocolVersion.NEWEST_SUPPORTED,
            codecRegistry);
        Token token = metadata.newToken(routingKey);
        for (TokenRange tokenRange : session.getCluster().getMetadata().getTokenRanges()) {
          if (tokenRange.contains(token)) {
            return tokenRange;
          }
        }
        log.warn("Unable to find any Cassandra node to insert token " + token.toString());
        return session.getCluster().getMetadata().getTokenRanges().iterator().next();
      })
      .flatMap(g -> g.compose(new BoundBatchStatementTransformer()))
      .flatMap(batch -> rxSession
          .execute(batch)
          .compose(applyInsertRetryPolicy())
          .map(resultSet -> batch.size())
      );
}

代码示例来源：origin: com.datastax.dse/dse-java-driver-core

@Test(groups = "short")
public void should_expose_token_and_range_creation_methods() {
 Metadata metadata = cluster().getMetadata();
 // Pick a random range
 TokenRange range = metadata.getTokenRanges().iterator().next();
 Token start = metadata.newToken(range.getStart().toString());
 Token end = metadata.newToken(range.getEnd().toString());
 assertThat(metadata.newTokenRange(start, end)).isEqualTo(range);
}

代码示例来源：origin: com.datastax.dse/dse-java-driver-core

@Test(groups = "short")
public void should_create_token_from_partition_key() {
 Metadata metadata = cluster().getMetadata();
 Row row = session().execute("SELECT token(i) FROM foo WHERE i = 1").one();
 Token expected = row.getToken(0);
 ProtocolVersion protocolVersion =
   cluster().getConfiguration().getProtocolOptions().getProtocolVersion();
 assertThat(metadata.newToken(TypeCodec.cint().serialize(1, protocolVersion)))
   .isEqualTo(expected);
}

代码示例来源：origin: com.datastax.dse/dse-java-driver-core

Token token1 = schemaDisabledCluster.getMetadata().newToken("0");
Token token2 = schemaDisabledCluster.getMetadata().newToken("111111");
assertThat(token1).isNotNull();
assertThat(token2).isNotNull();

代码示例来源：origin: org.janusgraph/janusgraph-cql

@Override
public KeyIterator getKeys(final KeyRangeQuery query, final StoreTransaction txh) throws BackendException {
  if (!this.storeManager.getFeatures().hasOrderedScan()) {
    throw new PermanentBackendException("This operation is only allowed when the byteorderedpartitioner is used.");
  }
  final Metadata metadata = this.session.getCluster().getMetadata();
  return Try.of(() -> new CQLResultSetKeyIterator(
      query,
      this.getter,
      this.session.execute(this.getKeysRanged.bind()
          .setToken(KEY_START_BINDING, metadata.newToken(query.getKeyStart().asByteBuffer()))
          .setToken(KEY_END_BINDING, metadata.newToken(query.getKeyEnd().asByteBuffer()))
          .setBytes(SLICE_START_BINDING, query.getSliceStart().asByteBuffer())
          .setBytes(SLICE_END_BINDING, query.getSliceEnd().asByteBuffer())
          .setFetchSize(this.storeManager.getPageSize())
          .setConsistencyLevel(getTransaction(txh).getReadConsistencyLevel()))))
      .getOrElseThrow(EXCEPTION_MAPPER);
}

代码示例来源：origin: com.datastax.dse/dse-java-driver-core

/**
 * Ensures that calling {@link Metadata#newToken(String)} on a Cluster that has schema metadata
 * disabled will throw a {@link IllegalStateException}.
 *
 * @jira_ticket JAVA-858
 * @since 2.0.11
 */
@Test(groups = "short", expectedExceptions = IllegalStateException.class)
public void should_throw_illegal_state_exception_on_newToken_with_metadata_disabled() {
 Cluster cluster =
   Cluster.builder()
     .addContactPoints(getContactPoints())
     .withPort(ccm().getBinaryPort())
     .withQueryOptions(nonDebouncingQueryOptions().setMetadataEnabled(false))
     .build();
 try {
  cluster.init();
  cluster.getMetadata().newToken("0x00");
 } finally {
  cluster.close();
 }
}

内容来源于网络，如有侵权，请联系作者删除！

Metadata

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    Metadata类方法

    • 蜀ICP备2022004421号-2 NULL123 https://www.null123.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com