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 |