程序包 com.cnosdb

接口 CnosDB

所有超级接口:
AutoCloseable
所有已知实现类:
CnosDBImpl
public interface CnosDB extends AutoCloseable
Interface with all available methods to access a CnosDB database. A full list of currently available interfaces is implemented in:
作者:
stefan.majer [at] gmail.com

  • 字段详细资料

  • 方法详细资料

    • setLogLevel

      CnosDB setLogLevel(CnosDB.LogLevel logLevel)
      Set the loglevel which is used for REST related actions.
      参数:
      logLevel - the loglevel to set.
      返回:
      the CnosDB instance to be able to use it in a fluent manner.

    • enableGzip

      CnosDB enableGzip()
      Enable Gzip compress for http request body.
      返回:
      the CnosDB instance to be able to use it in a fluent manner.

    • disableGzip

      CnosDB disableGzip()
      Disable Gzip compress for http request body.
      返回:
      the CnosDB instance to be able to use it in a fluent manner.

    • isGzipEnabled

      boolean isGzipEnabled()
      Returns whether Gzip compress for http request body is enabled.
      返回:
      true if gzip is enabled.

    • enableBatch

      CnosDB enableBatch()
      Enable batching of single Point writes to speed up writes significantly. This is the same as calling CnosDB.enableBatch(BatchOptions.DEFAULTS)
      返回:
      the CnosDB instance to be able to use it in a fluent manner.

    • enableBatch

      CnosDB enableBatch(BatchOptions batchOptions)
      Enable batching of single Point writes to speed up writes significantly. If either number of points written or flushDuration time limit is reached, a batch write is issued. Note that batch processing needs to be explicitly stopped before the application is shutdown. To do so call disableBatch().
      参数:
      batchOptions - the options to set for batching the writes.
      返回:
      the CnosDB instance to be able to use it in a fluent manner.

    • enableBatch

      CnosDB enableBatch(int actions, int flushDuration, TimeUnit flushDurationTimeUnit)
      Enable batching of single Point writes as enableBatch(int, int, TimeUnit, ThreadFactory)} using default thread factory.
      参数:
      actions - the number of actions to collect
      flushDuration - the time to wait at most.
      flushDurationTimeUnit - the TimeUnit for the given flushDuration.
      返回:
      the CnosDB instance to be able to use it in a fluent manner.
      另请参阅:

    • enableBatch

      CnosDB enableBatch(int actions, int flushDuration, TimeUnit flushDurationTimeUnit, ThreadFactory threadFactory)
      Enable batching of single Point writes as enableBatch(int, int, TimeUnit, ThreadFactory, BiConsumer) using with a exceptionHandler that does nothing.
      参数:
      actions - the number of actions to collect
      flushDuration - the time to wait at most.
      flushDurationTimeUnit - the TimeUnit for the given flushDuration.
      threadFactory - a ThreadFactory instance to be used.
      返回:
      the CnosDB instance to be able to use it in a fluent manner.
      另请参阅:

    • enableBatch

      CnosDB enableBatch(int actions, int flushDuration, TimeUnit flushDurationTimeUnit, ThreadFactory threadFactory, BiConsumer<Iterable<Point>,Throwable> exceptionHandler, CnosDB.ConsistencyLevel consistency)
      Enable batching of single Point writes with consistency set for an entire batch flushDurations is reached first, a batch write is issued. Note that batch processing needs to be explicitly stopped before the application is shutdown. To do so call disableBatch(). Default consistency is ONE.
      参数:
      actions - the number of actions to collect
      flushDuration - the time to wait at most.
      flushDurationTimeUnit - the TimeUnit for the given flushDuration.
      threadFactory - a ThreadFactory instance to be used.
      exceptionHandler - a consumer function to handle asynchronous errors
      consistency - a consistency setting for batch writes.
      返回:
      the CnosDB instance to be able to use it in a fluent manner.

    • enableBatch

      CnosDB enableBatch(int actions, int flushDuration, TimeUnit flushDurationTimeUnit, ThreadFactory threadFactory, BiConsumer<Iterable<Point>,Throwable> exceptionHandler)
      Enable batching of single Point writes to speed up writes significant. If either actions or flushDurations is reached first, a batch write is issued. Note that batch processing needs to be explicitly stopped before the application is shutdown. To do so call disableBatch().
      参数:
      actions - the number of actions to collect
      flushDuration - the time to wait at most.
      flushDurationTimeUnit - the TimeUnit for the given flushDuration.
      threadFactory - a ThreadFactory instance to be used.
      exceptionHandler - a consumer function to handle asynchronous errors
      返回:
      the CnosDB instance to be able to use it in a fluent manner.

    • disableBatch

      void disableBatch()
      Disable Batching.

    • isBatchEnabled

      boolean isBatchEnabled()
      Returns whether Batching is enabled.
      返回:
      true if batch is enabled.

    • ping

      Pong ping()
      Ping this cnosDB.
      返回:
      the response of the ping execution.

    • version

      String version()
      Return the version of the connected cnosDB Server.
      返回:
      the version String, otherwise unknown.

    • write

      void write(Point point)
      Write a single Point to the default database.
      参数:
      point - The point to write

    • write

      void write(String records)
      Write a set of Points to the default database with the string records.
      参数:
      records - the points in the correct lineprotocol.

    • write

      void write(List<String> records)
      Write a set of Points to the default database with the list of string records.
      参数:
      records - the List of points in the correct lineprotocol.

    • write

      void write(String database, String retentionPolicy, Point point)
      Write a single Point to the database.
      参数:
      database - the database to write to.
      retentionPolicy - the retentionPolicy to use.
      point - The point to write

    • write

      void write(int udpPort, Point point)
      Write a single Point to the database through UDP.
      参数:
      udpPort - the udpPort to write to.
      point - The point to write.

    • write

      void write(BatchPoints batchPoints)
      Write a set of Points to the cnosdb database with the new (>= 0.9.0rc32) lineprotocol.
      参数:
      batchPoints - the points to write in BatchPoints.
      另请参阅:

    • writeWithRetry

      void writeWithRetry(BatchPoints batchPoints)
      Write a set of Points to the cnosdb database with the new (>= 0.9.0rc32) lineprotocol. If batching is enabled with appropriate BatchOptions settings (BatchOptions.bufferLimit greater than BatchOptions.actions) This method will try to retry in case of some recoverable errors. Otherwise it just works as write(BatchPoints)
      参数:
      batchPoints - the points to write in BatchPoints.
      另请参阅:

    • write

      void write(String database, String retentionPolicy, CnosDB.ConsistencyLevel consistency, String records)
      Write a set of Points to the cnosdb database with the string records.
      参数:
      database - the name of the database to write
      retentionPolicy - the retentionPolicy to use
      consistency - the ConsistencyLevel to use
      records - the points in the correct lineprotocol.
      另请参阅:

    • write

      void write(String database, String retentionPolicy, CnosDB.ConsistencyLevel consistency, TimeUnit precision, String records)
      Write a set of Points to the cnosdb database with the string records.
      参数:
      database - the name of the database to write
      retentionPolicy - the retentionPolicy to use
      consistency - the ConsistencyLevel to use
      precision - the time precision to use
      records - the points in the correct lineprotocol.
      另请参阅:

    • write

      void write(String database, String retentionPolicy, CnosDB.ConsistencyLevel consistency, List<String> records)
      Write a set of Points to the cnosdb database with the list of string records.
      参数:
      database - the name of the database to write
      retentionPolicy - the retentionPolicy to use
      consistency - the ConsistencyLevel to use
      records - the List of points in the correct lineprotocol.
      另请参阅:

    • write

      void write(String database, String retentionPolicy, CnosDB.ConsistencyLevel consistency, TimeUnit precision, List<String> records)
      Write a set of Points to the cnosdb database with the list of string records.
      参数:
      database - the name of the database to write
      retentionPolicy - the retentionPolicy to use
      consistency - the ConsistencyLevel to use
      precision - the time precision to use
      records - the List of points in the correct lineprotocol.
      另请参阅:

    • write

      void write(int udpPort, String records)
      Write a set of Points to the cnosdb database with the string records through UDP.
      参数:
      udpPort - the udpPort where cnosdb is listening
      records - the content will be encoded by UTF-8 before sent.

    • write

      void write(int udpPort, List<String> records)
      Write a set of Points to the cnosdb database with the list of string records through UDP.
      参数:
      udpPort - the udpPort where cnosdb is listening
      records - list of record, the content will be encoded by UTF-8 before sent.

    • query

      QueryResult query(Query query)
      Execute a query against a database.
      参数:
      query - the query to execute.
      返回:
      a List of Series which matched the query.

    • query

      void query(Query query, Consumer<QueryResult> onSuccess, Consumer<Throwable> onFailure)
      Execute a query against a database. One of the consumers will be executed.
      参数:
      query - the query to execute.
      onSuccess - the consumer to invoke when result is received
      onFailure - the consumer to invoke when error is thrown

    • query

      void query(Query query, int chunkSize, Consumer<QueryResult> onNext)
      Execute a streaming query against a database.
      参数:
      query - the query to execute.
      chunkSize - the number of QueryResults to process in one chunk.
      onNext - the consumer to invoke for each received QueryResult

    • query

      void query(Query query, int chunkSize, BiConsumer<CnosDB.Cancellable,QueryResult> onNext)
      Execute a streaming query against a database.
      参数:
      query - the query to execute.
      chunkSize - the number of QueryResults to process in one chunk.
      onNext - the consumer to invoke for each received QueryResult; with capability to discontinue a streaming query

    • query

      void query(Query query, int chunkSize, Consumer<QueryResult> onNext, Runnable onComplete)
      Execute a streaming query against a database.
      参数:
      query - the query to execute.
      chunkSize - the number of QueryResults to process in one chunk.
      onNext - the consumer to invoke for each received QueryResult
      onComplete - the onComplete to invoke for successfully end of stream

    • query

      void query(Query query, int chunkSize, BiConsumer<CnosDB.Cancellable,QueryResult> onNext, Runnable onComplete)
      Execute a streaming query against a database.
      参数:
      query - the query to execute.
      chunkSize - the number of QueryResults to process in one chunk.
      onNext - the consumer to invoke for each received QueryResult; with capability to discontinue a streaming query
      onComplete - the onComplete to invoke for successfully end of stream

    • query

      void query(Query query, int chunkSize, BiConsumer<CnosDB.Cancellable,QueryResult> onNext, Runnable onComplete, Consumer<Throwable> onFailure)
      Execute a streaming query against a database.
      参数:
      query - the query to execute.
      chunkSize - the number of QueryResults to process in one chunk.
      onNext - the consumer to invoke for each received QueryResult; with capability to discontinue a streaming query
      onComplete - the onComplete to invoke for successfully end of stream
      onFailure - the consumer for error handling

    • query

      QueryResult query(Query query, TimeUnit timeUnit)
      Execute a query against a database.
      参数:
      query - the query to execute.
      timeUnit - the time unit of the results.
      返回:
      a List of Series which matched the query.

    • createDatabase

      @Deprecated void createDatabase(String name)
      已过时。
      (since 2.9, removed in 3.0) Use com.cnosdb.CnosDB.query(Query) to execute a parameterized CREATE DATABASE query.
      Create a new Database.
      参数:
      name - the name of the new database.

    • deleteDatabase

      @Deprecated void deleteDatabase(String name)
      已过时。
      (since 2.9, removed in 3.0) Use com.cnosdb.CnosDB.query(Query) to execute a DROP DATABASE query.
      Delete a database.
      参数:
      name - the name of the database to delete.

    • describeDatabases

      @Deprecated List<String> describeDatabases()
      已过时。
      (since 2.9, removed in 3.0) Use com.cnosdb.CnosDB.query(Query) to execute a SHOW DATABASES query.
      Describe all available databases.
      返回:
      a List of all Database names.

    • databaseExists

      @Deprecated boolean databaseExists(String name)
      已过时。
      (since 2.9, removed in 3.0) Use com.cnosdb.CnosDB.query(Query) to execute a SHOW DATABASES query and inspect the result.
      Check if a database exists.
      参数:
      name - the name of the database to search.
      返回:
      true if the database exists or false if it doesn't exist

    • flush

      void flush()
      Send any buffered points to CnosDB. This method is synchronous and will block while all pending points are written.
      抛出:
      IllegalStateException - if batching is not enabled.

    • close

      void close()
      close thread for asynchronous batch write and UDP socket to release resources if need.
      指定者:
      close 在接口中 AutoCloseable

    • setConsistency

      CnosDB setConsistency(CnosDB.ConsistencyLevel consistency)
      Set the consistency level which is used for writing points.
      参数:
      consistency - the consistency level to set.
      返回:
      the CnosDB instance to be able to use it in a fluent manner.

    • setDatabase

      CnosDB setDatabase(String database)
      Set the database which is used for writing points.
      参数:
      database - the database to set.
      返回:
      the CnosDB instance to be able to use it in a fluent manner.

    • setRetentionPolicy

      CnosDB setRetentionPolicy(String retentionPolicy)
      Set the retention policy which is used for writing points.
      参数:
      retentionPolicy - the retention policy to set.
      返回:
      the CnosDB instance to be able to use it in a fluent manner.

    • createRetentionPolicy

      @Deprecated void createRetentionPolicy(String rpName, String database, String duration, String shardDuration, int replicationFactor, boolean isDefault)
      已过时。
      (since 2.9, removed in 3.0) Use com.cnosdb.CnosDB.query(Query) to execute a parameterized CREATE RETENTION POLICY query.
      Creates a retentionPolicy.
      参数:
      rpName - the name of the retentionPolicy(rp)
      database - the name of the database
      duration - the duration of the rp
      shardDuration - the shardDuration
      replicationFactor - the replicationFactor of the rp
      isDefault - if the rp is the default rp for the database or not

    • createRetentionPolicy

      @Deprecated void createRetentionPolicy(String rpName, String database, String duration, int replicationFactor, boolean isDefault)
      已过时。
      (since 2.9, removed in 3.0) Use com.cnosdb.CnosDB.query(Query) to execute a parameterized CREATE RETENTION POLICY query.
      Creates a retentionPolicy. (optional shardDuration)
      参数:
      rpName - the name of the retentionPolicy(rp)
      database - the name of the database
      duration - the duration of the rp
      replicationFactor - the replicationFactor of the rp
      isDefault - if the rp is the default rp for the database or not

    • createRetentionPolicy

      @Deprecated void createRetentionPolicy(String rpName, String database, String duration, String shardDuration, int replicationFactor)
      已过时。
      (since 2.9, removed in 3.0) Use com.cnosdb.CnosDB.query(Query) to execute a parameterized CREATE RETENTION POLICY query.
      Creates a retentionPolicy. (optional shardDuration and isDefault)
      参数:
      rpName - the name of the retentionPolicy(rp)
      database - the name of the database
      duration - the duration of the rp
      shardDuration - the shardDuration
      replicationFactor - the replicationFactor of the rp

    • dropRetentionPolicy

      @Deprecated void dropRetentionPolicy(String rpName, String database)
      已过时。
      (since 2.9, removed in 3.0) Use com.cnosdb.CnosDB.query(Query) to execute a DROP RETENTION POLICY query.
      Drops a retentionPolicy in a database.
      参数:
      rpName - the name of the retentionPolicy
      database - the name of the database