@RestController
@Api(value = "api", basePath = "/api", description = "Aggregation API")
public class AggregationAPI extends APIService {
@RequestMapping(value = "/api/aggregate", method = POST, consumes = APPLICATION_JSON_VALUE, produces = APPLICATION_JSON_VALUE)
@ApiOperation(value = "Compute aggregation", consumes = APPLICATION_JSON_VALUE, produces = APPLICATION_JSON_VALUE, notes = "Compute aggregation according to the given parameters")
<BUG>public StreamingResponseBody compute(@RequestBody @Valid final AggregationParameters input) {
</BUG>
LOG.debug("Aggregation computation requested (pool: {} )...", getConnectionStats());
try {
<BUG>HystrixCommand<InputStream> command = getCommand(Aggregate.class, input);
</BUG>
return CommandHelper.toStreaming(command);

@RestController
@Api(value = "api", basePath = "/api", description = "Aggregation API")
public class AggregationAPI extends APIService {
@RequestMapping(value = "/api/aggregate", method = POST, consumes = APPLICATION_JSON_VALUE, produces = APPLICATION_JSON_VALUE)
@ApiOperation(value = "Compute aggregation", consumes = APPLICATION_JSON_VALUE, produces = APPLICATION_JSON_VALUE, notes = "Compute aggregation according to the given parameters")
public ResponseEntity<StreamingResponseBody> compute(@RequestBody @Valid final AggregationParameters input) {
LOG.debug("Aggregation computation requested (pool: {} )...", getConnectionStats());
try {
GenericCommand<InputStream> command = getCommand(Aggregate.class, input);
return CommandHelper.toStreaming(command);
