From c3e4a73996c7927adefab3532115dc2100e1e1bf Mon Sep 17 00:00:00 2001 From: Commit User Date: Wed, 17 Jul 2024 11:40:51 +0200 Subject: [PATCH] fix(pinot): query options --- src/client/broker/broker-client.ts | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/src/client/broker/broker-client.ts b/src/client/broker/broker-client.ts index e6a41ff..f295ba1 100644 --- a/src/client/broker/broker-client.ts +++ b/src/client/broker/broker-client.ts @@ -20,7 +20,7 @@ export class PinotClient implements IPinotClient { private static ENDPOINTS = { sql: '/query/sql' }; - private static stringifyOptions( + private static toQueryOptions( options?: IPinotQueryOptions, ): string | undefined { return options @@ -49,7 +49,7 @@ export class PinotClient implements IPinotClient { path: PinotClient.ENDPOINTS.sql, body: JSON.stringify({ sql, - options: PinotClient.stringifyOptions(options), + queryOptions: PinotClient.toQueryOptions(options), trace, }), }); @@ -64,7 +64,7 @@ export class PinotClient implements IPinotClient { first: response.resultTable?.rows?.slice(0, 3), last: response.resultTable?.rows?.slice(-3), sql, - options, + queryOptions: PinotClient.toQueryOptions(options), }, }); } @@ -135,7 +135,7 @@ export class PinotClient implements IPinotClient { cause: error as Error, data: { sql, - options, + queryOptions: PinotClient.toQueryOptions(options), first: response.resultTable?.rows?.slice(0, 3), last: response.resultTable?.rows?.slice(-3), },