Class InfluxDBQueryable<T>
Main entry point to query InfluxDB by LINQ
Inheritance
Namespace: InfluxDB.Client.Linq
Assembly: InfluxDB.Client.Linq.dll
Syntax
public class InfluxDBQueryable<T> : QueryableBase<T>
Type Parameters
| Name | Description |
|---|---|
| T |
Constructors
InfluxDBQueryable(IQueryProvider, System.Linq.Expressions.Expression)
Call by ReLinq.
Declaration
public InfluxDBQueryable(IQueryProvider provider, System.Linq.Expressions.Expression expression)
Parameters
| Type | Name | Description |
|---|---|---|
| IQueryProvider | provider | |
| System.Linq.Expressions.Expression | expression |
InfluxDBQueryable(String, String, QueryApi, IMemberNameResolver, QueryableOptimizerSettings)
Create a new instance of IQueryable for asynchronous Queries.
Declaration
public InfluxDBQueryable(string bucket, string org, QueryApi queryApi, IMemberNameResolver memberResolver, QueryableOptimizerSettings queryableOptimizerSettings = null)
Parameters
| Type | Name | Description |
|---|---|---|
| System.String | bucket | Specifies the source bucket. |
| System.String | org | Specifies the source organization. |
| QueryApi | queryApi | The underlying API to execute Flux Query. |
| IMemberNameResolver | memberResolver | Resolver for customized names. |
| QueryableOptimizerSettings | queryableOptimizerSettings | Settings for a Query optimization |
InfluxDBQueryable(String, String, QueryApiSync, IMemberNameResolver, QueryableOptimizerSettings)
Create a new instance of IQueryable for synchronous Queries.
Declaration
public InfluxDBQueryable(string bucket, string org, QueryApiSync queryApi, IMemberNameResolver memberResolver, QueryableOptimizerSettings queryableOptimizerSettings = null)
Parameters
| Type | Name | Description |
|---|---|---|
| System.String | bucket | Specifies the source bucket. |
| System.String | org | Specifies the source organization. |
| QueryApiSync | queryApi | The underlying API to execute Flux Query. |
| IMemberNameResolver | memberResolver | Resolver for customized names. |
| QueryableOptimizerSettings | queryableOptimizerSettings | Settings for a Query optimization |
Methods
GetAsyncEnumerator(CancellationToken)
Declaration
public IAsyncEnumerable<T> GetAsyncEnumerator(CancellationToken cancellationToken = null)
Parameters
| Type | Name | Description |
|---|---|---|
| CancellationToken | cancellationToken |
Returns
| Type | Description |
|---|---|
| IAsyncEnumerable<T> |
Queryable(String, String, QueryApi, IMemberNameResolver, QueryableOptimizerSettings)
Create a new instance of IQueryable for asynchronous Queries.
Declaration
public static InfluxDBQueryable<T> Queryable(string bucket, string org, QueryApi queryApi, IMemberNameResolver memberResolver, QueryableOptimizerSettings queryableOptimizerSettings = null)
Parameters
| Type | Name | Description |
|---|---|---|
| System.String | bucket | Specifies the source bucket. |
| System.String | org | Specifies the source organization. |
| QueryApi | queryApi | The underlying API to execute Flux Query. |
| IMemberNameResolver | memberResolver | Resolver for customized names. |
| QueryableOptimizerSettings | queryableOptimizerSettings | Settings for a Query optimization |
Returns
| Type | Description |
|---|---|
| InfluxDBQueryable<T> | new instance for of Queryable |
Queryable(String, String, QueryApi, QueryableOptimizerSettings)
Create a new instance of IQueryable for asynchronous Queries.
Declaration
public static InfluxDBQueryable<T> Queryable(string bucket, string org, QueryApi queryApi, QueryableOptimizerSettings queryableOptimizerSettings = null)
Parameters
| Type | Name | Description |
|---|---|---|
| System.String | bucket | Specifies the source bucket. |
| System.String | org | Specifies the source organization. |
| QueryApi | queryApi | The underlying API to execute Flux Query. |
| QueryableOptimizerSettings | queryableOptimizerSettings | Settings for a Query optimization |
Returns
| Type | Description |
|---|---|
| InfluxDBQueryable<T> | new instance for of Queryable |
Queryable(String, String, QueryApiSync, IMemberNameResolver, QueryableOptimizerSettings)
Create a new instance of IQueryable for synchronous Queries.
Declaration
public static InfluxDBQueryable<T> Queryable(string bucket, string org, QueryApiSync queryApi, IMemberNameResolver memberResolver, QueryableOptimizerSettings queryableOptimizerSettings = null)
Parameters
| Type | Name | Description |
|---|---|---|
| System.String | bucket | Specifies the source bucket. |
| System.String | org | Specifies the source organization. |
| QueryApiSync | queryApi | The underlying API to execute Flux Query. |
| IMemberNameResolver | memberResolver | Resolver for customized names. |
| QueryableOptimizerSettings | queryableOptimizerSettings | Settings for a Query optimization |
Returns
| Type | Description |
|---|---|
| InfluxDBQueryable<T> | new instance for of Queryable |
Queryable(String, String, QueryApiSync, QueryableOptimizerSettings)
Create a new instance of IQueryable for synchronous Queries.
Declaration
public static InfluxDBQueryable<T> Queryable(string bucket, string org, QueryApiSync queryApi, QueryableOptimizerSettings queryableOptimizerSettings = null)
Parameters
| Type | Name | Description |
|---|---|---|
| System.String | bucket | Specifies the source bucket. |
| System.String | org | Specifies the source organization. |
| QueryApiSync | queryApi | The underlying API to execute Flux Query. |
| QueryableOptimizerSettings | queryableOptimizerSettings | Settings for a Query optimization |
Returns
| Type | Description |
|---|---|
| InfluxDBQueryable<T> | new instance for of Queryable |
ToDebugQuery()
Create a Query object that will be used for Querying.
Declaration
public Query ToDebugQuery()
Returns
| Type | Description |
|---|---|
| Query | Query that will be used to Querying |