Apache/druid
1
0
Fork 0
mirror of https://github.com/apache/druid.git synced 2025-02-17 07:25:02 +00:00
Code Issues Packages Projects Releases Wiki Activity

Support segment metadata in rune (#7371)

Browse Source
This commit is contained in:
Qi Shu 2019-03-29 15:46:09 -07:00 committed by Clint Wylie
parent 347779b17a
commit 2ad9544242
1 changed files with 12 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
web-console/src/utils/rune-decoder.tsx
View File

@ -29,7 +29,8 @@ const SUPPORTED_QUERY_TYPES: string[] = [
'timeBoundary',
'dataSourceMetadata',
'select',
'scan'
'scan',
'segmentMetadata'
];
function flatArrayToHeaderRows(a: Record<string, any>[], headerOverride?: string[]): HeaderRows {
@ -73,6 +74,13 @@ function processScan(rune: any[]): HeaderRows {
return flatArrayToHeaderRows([].concat(...rune.map(r => r.events)), header);
}
function processSegmentMetadata(rune: any[]): HeaderRows {
const flatArray = ([] as any).concat(...rune.map(r => Object.keys(r.columns).map(
k => Object.assign({id: r.id, column: k}, r.columns[k])
)));
return flatArrayToHeaderRows(flatArray);
}
export function decodeRune(runeQuery: any, runeResult: any[]): HeaderRows {
let queryType = runeQuery.queryType;
if (typeof queryType !== 'string') throw new Error('must have queryType');
@ -122,6 +130,9 @@ export function decodeRune(runeQuery: any, runeResult: any[]): HeaderRows {
}
return processScan(runeResult);
case 'segmentMetadata':
return processSegmentMetadata(runeResult);
default:
throw new Error(`Should never get here.`);
}