Skip to content

Commit 4858659

Browse files
committed
add date to rowkey
1 parent fd97b6e commit 4858659

File tree

1 file changed

+10
-3
lines changed

1 file changed

+10
-3
lines changed

lib/aggregation/fees.js

Lines changed: 10 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -227,6 +227,7 @@ FeesAggregation.prototype.aggregate = function() {
227227

228228
function addFeeSummary(data) {
229229
var interval = data.interval || 'ledger';
230+
var date = smoment(data.date);
230231
var rowkey;
231232
var date;
232233

@@ -242,11 +243,17 @@ FeesAggregation.prototype.aggregate = function() {
242243
};
243244

244245
if (interval === 'ledger') {
245-
rowkey = 'ledger|' + utils.padNumber(data.ledger_index, LI_PAD);
246+
rowkey = [
247+
'ledger',
248+
date.hbaseFormatStartRow(),
249+
utils.padNumber(data.ledger_index, LI_PAD)
250+
].join('|');
246251
} else {
247-
date = smoment(data.date);
248252
date.moment.startOf(interval);
249-
rowkey = interval + '|' + date.hbaseFormatStartRow();
253+
rowkey = [
254+
interval,
255+
date.hbaseFormatStartRow()
256+
].join('|');
250257
}
251258

252259
rows[rowkey] = columns;

0 commit comments

Comments
 (0)