Packages

c

com.influxdb.client.scala.internal

QueryScalaApiImpl

class QueryScalaApiImpl extends AbstractQueryApi with QueryScalaApi

Linear Supertypes
QueryScalaApi, AbstractQueryApi, AbstractRestClient, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. QueryScalaApiImpl
  2. QueryScalaApi
  3. AbstractQueryApi
  4. AbstractRestClient
  5. AnyRef
  6. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new QueryScalaApiImpl(service: QueryService, options: InfluxDBClientOptions)

Type Members

  1. final class FluxRecordIterator extends Iterator[FluxRecord] with Closeable with Consumer[ResponseBody]
    Attributes
    protected[influxdb.internal]
    Definition Classes
    AbstractQueryApi
  2. final class RawIterator extends Iterator[String] with Closeable with Consumer[ResponseBody]
    Attributes
    protected[influxdb.internal]
    Definition Classes
    AbstractQueryApi

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. def createBody(arg0: String, arg1: String): RequestBody
    Attributes
    protected[influxdb.internal]
    Definition Classes
    AbstractQueryApi
    Annotations
    @Nonnull()
  7. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  8. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  9. def execute[T <: AnyRef](arg0: Call[T]): T
    Attributes
    protected[influxdb.internal]
    Definition Classes
    AbstractRestClient
    Annotations
    @throws(classOf[com.influxdb.exceptions.InfluxException])
  10. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @IntrinsicCandidate()
  11. def getLogLevel(arg0: HttpLoggingInterceptor): LogLevel
    Attributes
    protected[influxdb.internal]
    Definition Classes
    AbstractRestClient
    Annotations
    @Nonnull()
  12. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @IntrinsicCandidate()
  13. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  14. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  15. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @IntrinsicCandidate()
  16. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @IntrinsicCandidate()
  17. def ping(arg0: Call[ResponseBody]): Boolean
    Attributes
    protected[influxdb.internal]
    Definition Classes
    AbstractRestClient
    Annotations
    @Nonnull()
  18. 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

    Definition Classes
    QueryScalaApiImpl → QueryScalaApi
  19. 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

    Definition Classes
    QueryScalaApiImpl → QueryScalaApi
  20. 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

    Definition Classes
    QueryScalaApiImpl → QueryScalaApi
  21. 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

    Definition Classes
    QueryScalaApiImpl → QueryScalaApi
  22. 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

    Definition Classes
    QueryScalaApiImpl → QueryScalaApi
  23. 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

    Definition Classes
    QueryScalaApiImpl → QueryScalaApi
  24. 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

    Definition Classes
    QueryScalaApiImpl → QueryScalaApi
  25. 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

    Definition Classes
    QueryScalaApiImpl → QueryScalaApi
  26. def query(arg0: Call[ResponseBody], arg1: BiConsumer[Cancellable, BufferedSource], arg2: Consumer[_ >: Throwable <: AnyRef], arg3: Runnable, arg4: Boolean): Unit
    Attributes
    protected[influxdb.internal]
    Definition Classes
    AbstractQueryApi
  27. def query(arg0: Call[ResponseBody], arg1: FluxResponseConsumer, arg2: Consumer[_ >: Throwable <: AnyRef], arg3: Runnable, arg4: Boolean): Unit
    Attributes
    protected[influxdb.internal]
    Definition Classes
    AbstractQueryApi
  28. def queryIterator(arg0: Call[ResponseBody]): FluxRecordIterator
    Attributes
    protected[influxdb.internal]
    Definition Classes
    AbstractQueryApi
  29. 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

    Definition Classes
    QueryScalaApiImpl → QueryScalaApi
  30. 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

    Definition Classes
    QueryScalaApiImpl → QueryScalaApi
  31. 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

    Definition Classes
    QueryScalaApiImpl → QueryScalaApi
  32. 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

    Definition Classes
    QueryScalaApiImpl → QueryScalaApi
  33. 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

    Definition Classes
    QueryScalaApiImpl → QueryScalaApi
  34. 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

    Definition Classes
    QueryScalaApiImpl → QueryScalaApi
  35. def queryRaw(arg0: Call[ResponseBody], arg1: BiConsumer[Cancellable, String], arg2: Consumer[_ >: Throwable <: AnyRef], arg3: Runnable, arg4: Boolean): Unit
    Attributes
    protected[influxdb.internal]
    Definition Classes
    AbstractQueryApi
  36. def queryRawIterator(arg0: Call[ResponseBody]): RawIterator
    Attributes
    protected[influxdb.internal]
    Definition Classes
    AbstractQueryApi
  37. def responseToError(arg0: Response[_ <: AnyRef]): InfluxException
    Attributes
    protected[influxdb.internal]
    Definition Classes
    AbstractRestClient
    Annotations
    @Nonnull()
  38. def setLogLevel(arg0: HttpLoggingInterceptor, arg1: LogLevel): Unit
    Attributes
    protected[influxdb.internal]
    Definition Classes
    AbstractRestClient
  39. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  40. def toInfluxException(arg0: Throwable): InfluxException
    Attributes
    protected[influxdb.internal]
    Definition Classes
    AbstractRestClient
    Annotations
    @Nonnull()
  41. def toString(): String
    Definition Classes
    AnyRef → Any
  42. def version(arg0: Call[ResponseBody]): String
    Attributes
    protected[influxdb.internal]
    Definition Classes
    AbstractRestClient
    Annotations
    @Nonnull()
  43. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  44. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  45. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  46. object FluxRecordIterator
    Attributes
    protected[influxdb.internal]
    Definition Classes
    AbstractQueryApi
  47. object RawIterator
    Attributes
    protected[influxdb.internal]
    Definition Classes
    AbstractQueryApi

Deprecated Value Members

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

Inherited from QueryScalaApi

Inherited from AbstractQueryApi

Inherited from AbstractRestClient

Inherited from AnyRef

Inherited from Any

Ungrouped