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

x33g5p2x  于2022-01-18 转载在 其他  
字(10.2k)|赞(0)|评价(0)|浏览(179)

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

Cluster.checkNotClosed介绍

暂无

代码示例

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

  1. /**
  2.  * The cluster metrics.
  3.  *
  4.  * @return the cluster metrics, or {@code null} if this cluster has not yet been {@link #init()
  5.  *     initialized}, or if metrics collection has been disabled (that is if {@link
  6.  *     Configuration#getMetricsOptions} returns {@code null}).
  7.  */
  8. public Metrics getMetrics() {
  9.  checkNotClosed(manager);
  10.  return manager.metrics;
  11. }

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

  1. /**
  2.  * Creates a new session on this cluster but does not initialize it.
  3.  *
  4.  * <p>Because this method does not perform any initialization, it cannot fail. The initialization
  5.  * of the session (the connection of the Session to the Cassandra nodes) will occur if either the
  6.  * {@link Session#init} method is called explicitly, or whenever the returned session object is
  7.  * used.
  8.  *
  9.  * <p>Once a session returned by this method gets initialized (see above), it will be set to no
  10.  * keyspace. If you want to set such session to a keyspace, you will have to explicitly execute a
  11.  * 'USE mykeyspace' query.
  12.  *
  13.  * <p>Note that if you do not particularly need to defer initialization, it is simpler to use one
  14.  * of the {@code connect()} method of this class.
  15.  *
  16.  * @return a new, non-initialized session on this cluster.
  17.  */
  18. public Session newSession() {
  19.  checkNotClosed(manager);
  20.  return manager.newSession();
  21. }

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

  1. /**
  2.  * Unregisters the provided latency tracking from being updated with host read latencies.
  3.  *
  4.  * <p>This method is a no-op if {@code tracker} hasn't previously been registered against this
  5.  * Cluster.
  6.  *
  7.  * @param tracker the {@link LatencyTracker} to unregister.
  8.  * @return this {@code Cluster} object;
  9.  */
  10. public Cluster unregister(LatencyTracker tracker) {
  11.  checkNotClosed(manager);
  12.  boolean removed = manager.latencyTrackers.remove(tracker);
  13.  if (removed) tracker.onUnregister(this);
  14.  return this;
  15. }

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

  1. /**
  2.  * Unregisters the provided schema change listener from being updated with schema change events.
  3.  *
  4.  * <p>This method is a no-op if {@code listener} hasn't previously been registered against this
  5.  * Cluster.
  6.  *
  7.  * @param listener the {@link SchemaChangeListener} to unregister.
  8.  * @return this {@code Cluster} object;
  9.  */
  10. public Cluster unregister(SchemaChangeListener listener) {
  11.  checkNotClosed(manager);
  12.  boolean removed = manager.schemaChangeListeners.remove(listener);
  13.  if (removed) listener.onUnregister(this);
  14.  return this;
  15. }

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

  1. /**
  2.  * Unregisters the provided listener from being notified on hosts events.
  3.  *
  4.  * <p>This method is a no-op if {@code listener} hasn't previously been registered against this
  5.  * Cluster.
  6.  *
  7.  * @param listener the {@link Host.StateListener} to unregister.
  8.  * @return this {@code Cluster} object;
  9.  */
  10. public Cluster unregister(Host.StateListener listener) {
  11.  checkNotClosed(manager);
  12.  boolean removed = manager.listeners.remove(listener);
  13.  if (removed) listener.onUnregister(this);
  14.  return this;
  15. }

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

  1. /**
  2.  * Registers the provided listener to be updated with schema change events.
  3.  *
  4.  * <p>Registering the same listener multiple times is a no-op.
  5.  *
  6.  * @param listener the new {@link SchemaChangeListener} to register.
  7.  * @return this {@code Cluster} object;
  8.  */
  9. public Cluster register(SchemaChangeListener listener) {
  10.  checkNotClosed(manager);
  11.  boolean added = manager.schemaChangeListeners.add(listener);
  12.  if (added) listener.onRegister(this);
  13.  return this;
  14. }

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

  1. /**
  2.  * Registers the provided listener to be notified on hosts up/down/added/removed events.
  3.  *
  4.  * <p>Registering the same listener multiple times is a no-op.
  5.  *
  6.  * <p>This method should be used to register additional listeners on an already-initialized
  7.  * cluster. To add listeners to a cluster object prior to its initialization, use {@link
  8.  * Builder#withInitialListeners(Collection)}. Calling this method on a non-initialized cluster
  9.  * will result in the listener being {@link
  10.  * com.datastax.driver.core.Host.StateListener#onRegister(Cluster) notified} twice of cluster
  11.  * registration: once inside this method, and once at cluster initialization.
  12.  *
  13.  * @param listener the new {@link Host.StateListener} to register.
  14.  * @return this {@code Cluster} object;
  15.  */
  16. public Cluster register(Host.StateListener listener) {
  17.  checkNotClosed(manager);
  18.  boolean added = manager.listeners.add(listener);
  19.  if (added) listener.onRegister(this);
  20.  return this;
  21. }

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

  1. /**
  2.  * Registers the provided tracker to be updated with hosts read latencies.
  3.  *
  4.  * <p>Registering the same tracker multiple times is a no-op.
  5.  *
  6.  * <p>Beware that the registered tracker's {@link LatencyTracker#update(Host, Statement,
  7.  * Exception, long) update} method will be called very frequently (at the end of every query to a
  8.  * Cassandra host) and should thus not be costly.
  9.  *
  10.  * <p>The main use case for a {@link LatencyTracker} is to allow load balancing policies to
  11.  * implement latency awareness. For example, {@link LatencyAwarePolicy} registers it's own
  12.  * internal {@code LatencyTracker} (automatically, you don't have to call this method directly).
  13.  *
  14.  * @param tracker the new {@link LatencyTracker} to register.
  15.  * @return this {@code Cluster} object;
  16.  */
  17. public Cluster register(LatencyTracker tracker) {
  18.  checkNotClosed(manager);
  19.  boolean added = manager.latencyTrackers.add(tracker);
  20.  if (added) tracker.onRegister(this);
  21.  return this;
  22. }

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

  1. /**
  2.  * The cluster metrics.
  3.  *
  4.  * @return the cluster metrics, or {@code null} if this cluster has not yet been {@link #init() initialized}, or if
  5.  * metrics collection has been disabled (that is if {@link Configuration#getMetricsOptions} returns {@code null}).
  6.  */
  7. public Metrics getMetrics() {
  8.   checkNotClosed(manager);
  9.   return manager.metrics;
  10. }

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

  1. /**
  2.  * The cluster metrics.
  3.  *
  4.  * @return the cluster metrics, or {@code null} if this cluster has not yet been {@link #init() initialized}, or if
  5.  * metrics collection has been disabled (that is if {@link Configuration#getMetricsOptions} returns {@code null}).
  6.  */
  7. public Metrics getMetrics() {
  8.   checkNotClosed(manager);
  9.   return manager.metrics;
  10. }

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

  1. /**
  2.  * The cluster metrics.
  3.  *
  4.  * @return the cluster metrics, or {@code null} if this cluster has not yet been {@link #init() initialized}, or if
  5.  * metrics collection has been disabled (that is if {@link Configuration#getMetricsOptions} returns {@code null}).
  6.  */
  7. public Metrics getMetrics() {
  8.   checkNotClosed(manager);
  9.   return manager.metrics;
  10. }

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

  1. checkNotClosed(manager);
  2. init();
  3. final Session session = manager.newSession();

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

  1. /**
  2.  * Registers the provided listener to be updated with schema change events.
  3.  * <p/>
  4.  * Registering the same listener multiple times is a no-op.
  5.  *
  6.  * @param listener the new {@link SchemaChangeListener} to register.
  7.  * @return this {@code Cluster} object;
  8.  */
  9. public Cluster register(SchemaChangeListener listener) {
  10.   checkNotClosed(manager);
  11.   boolean added = manager.schemaChangeListeners.add(listener);
  12.   if (added)
  13.     listener.onRegister(this);
  14.   return this;
  15. }

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

  1. /**
  2.  * Registers the provided listener to be updated with schema change events.
  3.  * <p/>
  4.  * Registering the same listener multiple times is a no-op.
  5.  *
  6.  * @param listener the new {@link SchemaChangeListener} to register.
  7.  * @return this {@code Cluster} object;
  8.  */
  9. public Cluster register(SchemaChangeListener listener) {
  10.   checkNotClosed(manager);
  11.   boolean added = manager.schemaChangeListeners.add(listener);
  12.   if (added)
  13.     listener.onRegister(this);
  14.   return this;
  15. }

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

  1. /**
  2.  * Unregisters the provided latency tracking from being updated
  3.  * with host read latencies.
  4.  * <p/>
  5.  * This method is a no-op if {@code tracker} hasn't previously been
  6.  * registered against this Cluster.
  7.  *
  8.  * @param tracker the {@link LatencyTracker} to unregister.
  9.  * @return this {@code Cluster} object;
  10.  */
  11. public Cluster unregister(LatencyTracker tracker) {
  12.   checkNotClosed(manager);
  13.   boolean removed = manager.latencyTrackers.remove(tracker);
  14.   if (removed)
  15.     tracker.onUnregister(this);
  16.   return this;
  17. }

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

  1. /**
  2.  * Unregisters the provided listener from being notified on hosts events.
  3.  * <p/>
  4.  * This method is a no-op if {@code listener} hasn't previously been
  5.  * registered against this Cluster.
  6.  *
  7.  * @param listener the {@link Host.StateListener} to unregister.
  8.  * @return this {@code Cluster} object;
  9.  */
  10. public Cluster unregister(Host.StateListener listener) {
  11.   checkNotClosed(manager);
  12.   boolean removed = manager.listeners.remove(listener);
  13.   if (removed)
  14.     listener.onUnregister(this);
  15.   return this;
  16. }

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

  1. /**
  2.  * Unregisters the provided schema change listener from being updated
  3.  * with schema change events.
  4.  * <p/>
  5.  * This method is a no-op if {@code listener} hasn't previously been
  6.  * registered against this Cluster.
  7.  *
  8.  * @param listener the {@link SchemaChangeListener} to unregister.
  9.  * @return this {@code Cluster} object;
  10.  */
  11. public Cluster unregister(SchemaChangeListener listener) {
  12.   checkNotClosed(manager);
  13.   boolean removed = manager.schemaChangeListeners.remove(listener);
  14.   if (removed)
  15.     listener.onUnregister(this);
  16.   return this;
  17. }

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

  1. /**
  2.  * Unregisters the provided listener from being notified on hosts events.
  3.  * <p/>
  4.  * This method is a no-op if {@code listener} hasn't previously been
  5.  * registered against this Cluster.
  6.  *
  7.  * @param listener the {@link Host.StateListener} to unregister.
  8.  * @return this {@code Cluster} object;
  9.  */
  10. public Cluster unregister(Host.StateListener listener) {
  11.   checkNotClosed(manager);
  12.   boolean removed = manager.listeners.remove(listener);
  13.   if (removed)
  14.     listener.onUnregister(this);
  15.   return this;
  16. }

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

  1. /**
  2.  * Registers the provided listener to be updated with schema change events.
  3.  * <p/>
  4.  * Registering the same listener multiple times is a no-op.
  5.  *
  6.  * @param listener the new {@link SchemaChangeListener} to register.
  7.  * @return this {@code Cluster} object;
  8.  */
  9. public Cluster register(SchemaChangeListener listener) {
  10.   checkNotClosed(manager);
  11.   boolean added = manager.schemaChangeListeners.add(listener);
  12.   if (added)
  13.     listener.onRegister(this);
  14.   return this;
  15. }

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

  1. /**
  2.  * Unregisters the provided schema change listener from being updated
  3.  * with schema change events.
  4.  * <p/>
  5.  * This method is a no-op if {@code listener} hasn't previously been
  6.  * registered against this Cluster.
  7.  *
  8.  * @param listener the {@link SchemaChangeListener} to unregister.
  9.  * @return this {@code Cluster} object;
  10.  */
  11. public Cluster unregister(SchemaChangeListener listener) {
  12.   checkNotClosed(manager);
  13.   boolean removed = manager.schemaChangeListeners.remove(listener);
  14.   if (removed)
  15.     listener.onUnregister(this);
  16.   return this;
  17. }

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

Cluster

相关文章

    查看更多

    热门标签

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

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com