NPM/numass-framework
4
0
Fork 1
Code Issues Pull Requests Packages Projects Releases Wiki Activity

KTask join fix

Browse Source
This commit is contained in:
Alexander Nozik 2018-07-15 21:33:52 +03:00
parent cce0372cf8
commit 4ccecbe4ed
1 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
numass-main/src/main/kotlin/inr/numass/tasks/NumassTasks.kt
View File

@ -280,6 +280,7 @@ val histogramTask = task("histogram") {
configure(meta.getMetaOrEmpty("histogram")) configure(meta.getMetaOrEmpty("histogram"))
configure { configure {
meta.useMeta("analyzer") { putNode(it) } meta.useMeta("analyzer") { putNode(it) }
setValue("@target", meta.getString("@target",meta.name))
} }
} }
join<NumassSet, Table> { data -> join<NumassSet, Table> { data ->
@ -299,6 +300,7 @@ val histogramTask = task("histogram") {
analyzer.getAmplitudeSpectrum(MetaBlock(it.value)) analyzer.getAmplitudeSpectrum(MetaBlock(it.value))
} }
.forEach { u, spectrum -> .forEach { u, spectrum ->
log.report("Aggregating data from U = $u")
spectrum.forEach { spectrum.forEach {
val channel = it[CHANNEL_KEY].int val channel = it[CHANNEL_KEY].int
val count = it[COUNT_KEY].long val count = it[COUNT_KEY].long
@ -309,12 +311,16 @@ val histogramTask = task("histogram") {
names.add("U$u") names.add("U$u")
} }
log.report("Combining spectra")
val format = MetaTableFormat.forNames(names) val format = MetaTableFormat.forNames(names)
val table = buildTable(format) { val table = buildTable(format) {
aggregator.forEach { channel, counters -> aggregator.forEach { channel, counters ->
val values: MutableMap<String, Any> = HashMap() val values: MutableMap<String, Any> = HashMap()
values["channel"] = channel values["channel"] = channel
counters.forEach { u, counter -> values["U$u"] = counter.get() } counters.forEach { u, counter -> values["U$u"] = counter.get() }
format.names.forEach {
values.putIfAbsent(it, 0)
}
row(values) row(values)
} }
} }