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

Cluster.timeSince介绍

暂无

代码示例

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

static boolean waitForSchemaAgreement(Connection connection, Cluster.Manager cluster)
  throws ConnectionException, BusyConnectionException, ExecutionException,
    InterruptedException {
 long start = System.nanoTime();
 long elapsed = 0;
 int maxSchemaAgreementWaitSeconds =
   cluster.configuration.getProtocolOptions().getMaxSchemaAgreementWaitSeconds();
 while (elapsed < maxSchemaAgreementWaitSeconds * 1000) {
  if (checkSchemaAgreement(connection, cluster)) return true;
  // let's not flood the node too much
  Thread.sleep(200);
  elapsed = Cluster.timeSince(start, TimeUnit.MILLISECONDS);
 }
 return false;
}

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

static boolean waitForSchemaAgreement(Connection connection, Cluster.Manager cluster) throws ConnectionException, BusyConnectionException, ExecutionException, InterruptedException {
  long start = System.nanoTime();
  long elapsed = 0;
  int maxSchemaAgreementWaitSeconds = cluster.configuration.getProtocolOptions().getMaxSchemaAgreementWaitSeconds();
  while (elapsed < maxSchemaAgreementWaitSeconds * 1000) {
    if (checkSchemaAgreement(connection, cluster))
      return true;
    // let's not flood the node too much
    Thread.sleep(200);
    elapsed = Cluster.timeSince(start, TimeUnit.MILLISECONDS);
  }
  return false;
}

代码示例来源：origin: io.prestosql.cassandra/cassandra-driver

static boolean waitForSchemaAgreement(Connection connection, Cluster.Manager cluster) throws ConnectionException, BusyConnectionException, ExecutionException, InterruptedException {
  long start = System.nanoTime();
  long elapsed = 0;
  int maxSchemaAgreementWaitSeconds = cluster.configuration.getProtocolOptions().getMaxSchemaAgreementWaitSeconds();
  while (elapsed < maxSchemaAgreementWaitSeconds * 1000) {
    if (checkSchemaAgreement(connection, cluster))
      return true;
    // let's not flood the node too much
    Thread.sleep(200);
    elapsed = Cluster.timeSince(start, TimeUnit.MILLISECONDS);
  }
  return false;
}

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

static boolean waitForSchemaAgreement(Connection connection, Cluster.Manager cluster) throws ConnectionException, BusyConnectionException, ExecutionException, InterruptedException {
  long start = System.nanoTime();
  long elapsed = 0;
  int maxSchemaAgreementWaitSeconds = cluster.configuration.getProtocolOptions().getMaxSchemaAgreementWaitSeconds();
  while (elapsed < maxSchemaAgreementWaitSeconds * 1000) {
    if (checkSchemaAgreement(connection, cluster))
      return true;
    // let's not flood the node too much
    Thread.sleep(200);
    elapsed = Cluster.timeSince(start, TimeUnit.MILLISECONDS);
  }
  return false;
}

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

remaining = timeout - Cluster.timeSince(start, unit);
} while (remaining > 0);

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

static boolean waitForSchemaAgreement(Connection connection, Cluster.Manager cluster) throws ConnectionException, BusyConnectionException, ExecutionException, InterruptedException {
  long start = System.nanoTime();
  long elapsed = 0;
  while (elapsed < MAX_SCHEMA_AGREEMENT_WAIT_MS) {
    DefaultResultSetFuture peersFuture = new DefaultResultSetFuture(null, new Requests.Query(SELECT_SCHEMA_PEERS));
    DefaultResultSetFuture localFuture = new DefaultResultSetFuture(null, new Requests.Query(SELECT_SCHEMA_LOCAL));
    connection.write(peersFuture);
    connection.write(localFuture);
    Set<UUID> versions = new HashSet<UUID>();
    Row localRow = localFuture.get().one();
    if (localRow != null && !localRow.isNull("schema_version"))
      versions.add(localRow.getUUID("schema_version"));
    for (Row row : peersFuture.get()) {
      InetSocketAddress addr = addressToUseForPeerHost(row, connection.address, cluster);
      if (addr == null || row.isNull("schema_version"))
        continue;
      Host peer = cluster.metadata.getHost(addr);
      if (peer != null && peer.isUp())
        versions.add(row.getUUID("schema_version"));
    }
    logger.debug("Checking for schema agreement: versions are {}", versions);
    if (versions.size() <= 1)
      return true;
    // let's not flood the node too much
    Thread.sleep(200);
    elapsed = Cluster.timeSince(start, TimeUnit.MILLISECONDS);
  }
  return false;
}