var reqs = stream |from() .measurement('testdata') var batched = reqs |window() .period(1m) .every(1m) var countFilter = batched |where(lambda: 1 == 2) var countBad = batched |sum('value') |log() var countGood = reqs |window() .period(1m) .every(1m) |sum('value') |log()