raghavyadav01 commented on code in PR #14251:
URL: https://github.com/apache/pinot/pull/14251#discussion_r1807473302
##########
pinot-core/src/main/java/org/apache/pinot/core/operator/timeseries/TimeSeriesAggregationOperator.java:
##########
@@ -82,55 +82,54 @@ public TimeSeriesAggregationOperator(
@Override
protected TimeSeriesResultsBlock getNextBlock() {
- ValueBlock transformBlock = _projectOperator.nextBlock();
- if (transformBlock == null) {
- TimeSeriesBuilderBlock builderBlock = new
TimeSeriesBuilderBlock(_timeBuckets, new HashMap<>());
- return new TimeSeriesResultsBlock(builderBlock);
- }
- BlockValSet blockValSet = transformBlock.getBlockValueSet(_timeColumn);
- long[] timeValues = blockValSet.getLongValuesSV();
- if (_timeOffset != null && _timeOffset != 0L) {
- timeValues = applyTimeshift(_timeOffset, timeValues);
- }
- int[] timeValueIndexes = getTimeValueIndex(timeValues, _storedTimeUnit);
- Object[][] tagValues = new Object[_groupByExpressions.size()][];
+ ValueBlock valueBlock;
Map<Long, BaseTimeSeriesBuilder> seriesBuilderMap = new HashMap<>(1024);
Review Comment:
Should we increase the limit of 1k series Builder Map?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
