commit | db6582c9e9dabef0eaee70c12a082bc5355794ae | [log] [tgz] |
---|---|---|
author | JArod <jarodwen@gmail.com> | Wed Jun 05 10:56:13 2013 -0700 |
committer | JArod <jarodwen@gmail.com> | Wed Jun 05 10:56:13 2013 -0700 |
tree | 2607d9c53c29f2a70a30060da917c741e5240d1b | |
parent | ea89a15ddde2710f5f05523ce7c17356cfb930df [diff] |
minor fix for local average aggregate
diff --git a/asterix-runtime/src/main/java/edu/uci/ics/asterix/runtime/aggregates/std/LocalAvgAggregateDescriptor.java b/asterix-runtime/src/main/java/edu/uci/ics/asterix/runtime/aggregates/std/LocalAvgAggregateDescriptor.java index 5ba9c06..256af09 100644 --- a/asterix-runtime/src/main/java/edu/uci/ics/asterix/runtime/aggregates/std/LocalAvgAggregateDescriptor.java +++ b/asterix-runtime/src/main/java/edu/uci/ics/asterix/runtime/aggregates/std/LocalAvgAggregateDescriptor.java
@@ -202,7 +202,7 @@ @Override public void finish() throws AlgebricksException { try { - if (count == 0) { + if (count == 0 && aggType != ATypeTag.NULL) { out.writeByte(ATypeTag.SYSTEM_NULL.serialize()); return; }