reduce memory usage
This commit is contained in:
@@ -51,7 +51,7 @@ public class ParallelRequestsAggregate extends AggregateHandler {
|
|||||||
@Override
|
@Override
|
||||||
public CustomAggregator createCustomAggregator(final Path tmpDir, final PlotSettings plotSettings,
|
public CustomAggregator createCustomAggregator(final Path tmpDir, final PlotSettings plotSettings,
|
||||||
final long fromEpochMilli, final long toEpochMilli) {
|
final long fromEpochMilli, final long toEpochMilli) {
|
||||||
if ((toEpochMilli - fromEpochMilli) <= TimeUnit.HOURS.toMillis(50)) {
|
if ((toEpochMilli - fromEpochMilli) <= TimeUnit.HOURS.toMillis(24)) {
|
||||||
return new ParallelRequestsAggregator(tmpDir, fromEpochMilli, toEpochMilli);
|
return new ParallelRequestsAggregator(tmpDir, fromEpochMilli, toEpochMilli);
|
||||||
} else {
|
} else {
|
||||||
return null;
|
return null;
|
||||||
|
|||||||
Reference in New Issue
Block a user