Elgato_dark/zeppelin
1
0
Fork 0
mirror of https://github.com/apache/zeppelin synced 2026-05-24 09:38:26 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

fix: Set proper aggr value when 0 group

Browse source
This commit is contained in:
1ambda 2017-03-19 12:22:04 +09:00
parent 20f9437de2
commit 812f9a2c64
1 changed files with 10 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
zeppelin-web/src/app/tabledata/advanced-transformation-util.js
View file

@ -473,8 +473,8 @@ export function getObjectRowsFromCube(cube, schema, aggregatorColumns,
const selectorSet = new Set()
const rows = keyNames.reduce((acc, key) => {
const keyed = cube[key]
const row = getObjectRow(schema, aggregatorColumns, keyed, groupNameSet, selectorSet)
const obj = cube[key]
const row = getObjectRow(schema, aggregatorColumns, obj, groupNameSet, selectorSet)
if (schema.key) { row[keyColumnName] = key }
acc.push(row)
@ -493,13 +493,20 @@ export function getObjectRow(schema, aggrColumns, obj, groupNameSet, selectorSet
if (!schema.group) {
for(let i = 0; i < aggrColumns.length; i++) {
const aggrColumn = aggrColumns[i]
const aggrName = aggrColumn.name
const selector = aggrColumn.name
selectorSet.add(selector)
let value = null
try {
value = obj[selector].value;
if (aggrColumn.aggr === Aggregator.AVG) {
value = aggrColumn[aggrName].value / aggrColumn[aggrName].count
} else if (aggrColumn.aggr === Aggregator.COUNT) {
value = aggrColumn[aggrName].count
} else {
value = aggrColumn[aggrName].value
}
if (typeof value === 'undefined') { value = null }
} catch (error) { /** iognore */ }