Packages

t

com.influxdb.client.scala

QueryScalaApi

trait QueryScalaApi extends AnyRef

The client that allows perform Flux queries against the InfluxDB /api/v2/query endpoint.

For parametrized queries use Query object, see com.influxdb.client.QueryApi in Java module for more details.

Linear Supertypes
AnyRef, Any
Known Subclasses
QueryScalaApiImpl
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. QueryScalaApi
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Abstract Value Members

  1. abstract def query[M](query: Query, org: String, measurementType: Class[M]): Source[M, NotUsed]

    Executes the Flux query against the InfluxDB and asynchronously stream measurements to Stream.

    Executes the Flux query against the InfluxDB and asynchronously stream measurements to Stream.

    M

    the type of the measurement (POJO)

    query

    the flux query to execute

    org

    specifies the source organization

    measurementType

    the measurement (POJO)

    returns

    the stream of measurements

    Annotations
    @Nonnull()
  2. abstract def query[M](query: Query, measurementType: Class[M]): Source[M, NotUsed]

    Executes the Flux query against the InfluxDB and asynchronously stream measurements to Stream.

    Executes the Flux query against the InfluxDB and asynchronously stream measurements to Stream.

    com.influxdb.client.InfluxDBClientOptions#getOrg() will be used as source organization.

    M

    the type of the measurement (POJO)

    query

    the flux query to execute

    measurementType

    the measurement (POJO)

    returns

    the stream of measurements

    Annotations
    @Nonnull()
  3. abstract def query[M](query: String, org: String, measurementType: Class[M]): Source[M, NotUsed]

    Executes the Flux query against the InfluxDB and asynchronously stream measurements to Stream.

    Executes the Flux query against the InfluxDB and asynchronously stream measurements to Stream.

    M

    the type of the measurement (POJO)

    query

    the flux query to execute

    org

    specifies the source organization

    measurementType

    the measurement (POJO)

    returns

    the stream of measurements

    Annotations
    @Nonnull()
  4. abstract def query[M](query: String, measurementType: Class[M]): Source[M, NotUsed]

    Executes the Flux query against the InfluxDB and asynchronously stream measurements to Stream.

    Executes the Flux query against the InfluxDB and asynchronously stream measurements to Stream.

    com.influxdb.client.InfluxDBClientOptions#getOrg() will be used as source organization.

    M

    the type of the measurement (POJO)

    query

    the flux query to execute

    measurementType

    the measurement (POJO)

    returns

    the stream of measurements

    Annotations
    @Nonnull()
  5. abstract def query(query: Query, org: String): Source[FluxRecord, NotUsed]

    Executes the Flux query against the InfluxDB and asynchronously stream FluxRecords to Stream.

    Executes the Flux query against the InfluxDB and asynchronously stream FluxRecords to Stream.

    query

    the flux query to execute

    org

    specifies the source organization

    returns

    the stream of FluxRecords

    Annotations
    @Nonnull()
  6. abstract def query(query: Query): Source[FluxRecord, NotUsed]

    Executes the Flux query against the InfluxDB and asynchronously stream FluxRecords to Stream.

    Executes the Flux query against the InfluxDB and asynchronously stream FluxRecords to Stream.

    com.influxdb.client.InfluxDBClientOptions#getOrg() will be used as source organization.

    query

    the flux query to execute

    returns

    the stream of FluxRecords

    Annotations
    @Nonnull()
  7. abstract def query(query: String, org: String): Source[FluxRecord, NotUsed]

    Executes the Flux query against the InfluxDB and asynchronously stream FluxRecords to Stream.

    Executes the Flux query against the InfluxDB and asynchronously stream FluxRecords to Stream.

    query

    the flux query to execute

    org

    specifies the source organization

    returns

    the stream of FluxRecords

    Annotations
    @Nonnull()
  8. abstract def query(query: String): Source[FluxRecord, NotUsed]

    Executes the Flux query against the InfluxDB and asynchronously stream FluxRecords to Stream.

    Executes the Flux query against the InfluxDB and asynchronously stream FluxRecords to Stream.

    com.influxdb.client.InfluxDBClientOptions#getOrg() will be used as source organization.

    query

    the flux query to execute

    returns

    the stream of FluxRecords

    Annotations
    @Nonnull()
  9. abstract def queryRaw(query: Query, org: String): Source[String, NotUsed]

    Executes the Flux query against the InfluxDB and asynchronously stream response to Stream.

    Executes the Flux query against the InfluxDB and asynchronously stream response to Stream.

    query

    the flux query to execute

    org

    specifies the source organization

    returns

    the response stream

    Annotations
    @Nonnull()
  10. abstract def queryRaw(query: Query): Source[String, NotUsed]

    Executes the Flux query against the InfluxDB and asynchronously stream response to Stream.

    Executes the Flux query against the InfluxDB and asynchronously stream response to Stream.

    com.influxdb.client.InfluxDBClientOptions#getOrg() will be used as source organization.

    query

    the flux query to execute

    returns

    the response stream

    Annotations
    @Nonnull()
  11. abstract def queryRaw(query: String, dialect: Dialect, org: String): Source[String, NotUsed]

    Executes the Flux query against the InfluxDB and asynchronously stream response to Stream.

    Executes the Flux query against the InfluxDB and asynchronously stream response to Stream.

    query

    the flux query to execute

    dialect

    Dialect is an object defining the options to use when encoding the response. See dialect SPEC.

    org

    specifies the source organization

    returns

    the response stream

    Annotations
    @Nonnull()
  12. abstract def queryRaw(query: String, dialect: Dialect): Source[String, NotUsed]

    Executes the Flux query against the InfluxDB and asynchronously stream response to Stream.

    Executes the Flux query against the InfluxDB and asynchronously stream response to Stream.

    com.influxdb.client.InfluxDBClientOptions#getOrg() will be used as source organization.

    query

    the flux query to execute

    dialect

    Dialect is an object defining the options to use when encoding the response. See dialect SPEC.

    returns

    the response stream

    Annotations
    @Nonnull()
  13. abstract def queryRaw(query: String, org: String): Source[String, NotUsed]

    Executes the Flux query against the InfluxDB and asynchronously stream response to Stream.

    Executes the Flux query against the InfluxDB and asynchronously stream response to Stream.

    query

    the flux query to execute

    org

    specifies the source organization

    returns

    the response stream

    Annotations
    @Nonnull()
  14. abstract def queryRaw(query: String): Source[String, NotUsed]

    Executes the Flux query against the InfluxDB and asynchronously stream response to Stream.

    Executes the Flux query against the InfluxDB and asynchronously stream response to Stream.

    com.influxdb.client.InfluxDBClientOptions#getOrg() will be used as source organization.

    query

    the flux query to execute

    returns

    the response stream

    Annotations
    @Nonnull()

Concrete Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native() @IntrinsicCandidate()
  6. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  7. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  8. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @IntrinsicCandidate()
  9. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @IntrinsicCandidate()
  10. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  11. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  12. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @IntrinsicCandidate()
  13. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @IntrinsicCandidate()
  14. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  15. def toString(): String
    Definition Classes
    AnyRef → Any
  16. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  17. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  18. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable]) @Deprecated @Deprecated
    Deprecated

Inherited from AnyRef

Inherited from Any

Ungrouped