in src/datasource.ts [336:385]
type: extractType(field.type.name),
});
}
}
for (let msg of response.data) {
frame.add(msg);
}
return { dataframe: frame };
})
)
.toPromise()
.catch((er: HttpError) => {
return { error: er };
});
}
executeQuery(
query: string,
range: TimeRange,
variableQuery: boolean,
type: string,
maxDataPoints?: number
): Observable<TimeSeries | DataFrame> {
if (type === DATAFRAME_KEY) {
return this.executeDataFrameQuery(query, range, variableQuery, maxDataPoints);
} else {
return this.executeTimeSeriesQuery(query, range, variableQuery, maxDataPoints);
}
}
executeTimeSeriesQuery(
query: string,
range: TimeRange,
variableQuery: boolean,
maxDataPoints?: number
): Observable<TimeSeries> {
return forkJoin({
schema: this.describeQuery(query),
data: this.rawQuery(query, range, variableQuery, maxDataPoints),
}).pipe(
map((response: { schema: TypeDef[]; data: any[] }) => {
const numeric = new Set<string>();
const map = new Map<string, TimeSeries>();
map.set('symbol', {
target: 'symbol',
datapoints: [],
});
for (let typeDef of response.schema) {
for (let field of typeDef.fields) {
map.set(field.name, {