feat(pinot-driver): Add enableNullHandling to query options using env var (#9213)

* Add enableNullHandling=true to query options using env var CUBEJS_DB_NULL_HANDLING

* Add 'The Startree/Pinot null value support' to docs

* fix reference env var

* Update docs/pages/product/configuration/data-sources/pinot.mdx

Co-authored-by: Konstantin Burkalev <[email protected]>

* Update docs/pages/reference/configuration/environment-variables.mdx

Co-authored-by: ron-damon <[email protected]>

* Update docs/pages/reference/configuration/environment-variables.mdx

Co-authored-by: ron-damon <[email protected]>

* Update packages/cubejs-backend-shared/src/env.ts

Co-authored-by: Konstantin Burkalev <[email protected]>

* fix env var name

---------

Co-authored-by: Konstantin Burkalev <[email protected]>
Co-authored-by: ron-damon <[email protected]>

Author: 3 people

docs/pages/product/configuration/data-sources/pinot.mdx

@@ -42,14 +42,15 @@ CUBEJS_DB_PASS=**********
 
 ## Environment Variables
 
-| Environment Variable | Description                                | Possible Values     | Required |
-|----------------------|--------------------------------------------|---------------------|:--------:|
-| `CUBEJS_DB_HOST`     | The host URL for your Pinot broker         | A valid host URL    |    ✅    |
-| `CUBEJS_DB_PORT`     | The port for the database connection       | A valid port number |    ✅    |
-| `CUBEJS_DB_USER`     | The username used to connect to the broker | A valid username    |    ❌    |
-| `CUBEJS_DB_PASS`     | The password used to connect to the broker | A valid password    |    ❌    |
-| `CUBEJS_DB_NAME`     | The database name for StarTree             | A valid name        |    ❌    |
-| `CUBEJS_DB_PINOT_AUTH_TOKEN` | The authentication token for StarTree | A valid token    |    ❌    |
+| Environment Variable            | Description                                           | Possible Values     | Required |
+|---------------------------------|-------------------------------------------------------|---------------------|:--------:|
+| `CUBEJS_DB_HOST`                | The host URL for your Pinot broker                    | A valid host URL    |    ✅    |
+| `CUBEJS_DB_PORT`                | The port for the database connection                  | A valid port number |    ✅    |
+| `CUBEJS_DB_USER`                | The username used to connect to the broker            | A valid username    |    ❌    |
+| `CUBEJS_DB_PASS`                | The password used to connect to the broker            | A valid password    |    ❌    |
+| `CUBEJS_DB_NAME`                | The database name for StarTree                        | A valid name        |    ❌    |
+| `CUBEJS_DB_PINOT_NULL_HANDLING` | If `true`, enables null handling. Default is `false`  | `true`, `false`     |    ❌    |
+| `CUBEJS_DB_PINOT_AUTH_TOKEN`    | The authentication token for StarTree                 | A valid token       |    ❌    |
 
 ## Pre-Aggregation Feature Support
 

docs/pages/reference/configuration/environment-variables.mdx

@@ -740,6 +740,15 @@ The Snowflake warehouse to use when connecting to the database.
 | ---------------------------------------------------------------------- | ---------------------- | --------------------- |
 | [A valid Snowflake warehouse][snowflake-docs-warehouse] in the account | N/A                    | N/A                   |
 
+## `CUBEJS_DB_PINOT_NULL_HANDLING`
+
+The Startree/Pinot null value support. If `true`, enables null handling.
+
+| Possible Values | Default in Development | Default in Production |
+| --------------- | ---------------------- | --------------------- |
+| `true`, `false` |	`false`                | `false`               |
+
+
 ## `CUBEJS_DB_SSL`
 
 If `true`, enables SSL encryption for database connections from Cube.

packages/cubejs-backend-shared/src/env.ts

@@ -1780,6 +1780,35 @@ const variables: Record<string, (...args: any) => any> = {
     ]
   ),
 
+  /**
+   * Pinot / Startree Null value support
+   */
+
+  pinotNullHandling: ({ dataSource }: { dataSource: string }) => {
+    const val = process.env[
+      keyByDataSource('CUBEJS_DB_PINOT_NULL_HANDLING', dataSource)
+    ];
+
+    if (val) {
+      if (val.toLocaleLowerCase() === 'true') {
+        return true;
+      } else if (val.toLowerCase() === 'false') {
+        return false;
+      } else {
+        throw new TypeError(
+          `The ${
+            keyByDataSource(
+              'CUBEJS_DB_PINOT_NULL_HANDLING',
+              dataSource,
+            )
+          } must be either 'true' or 'false'.`
+        );
+      }
+    } else {
+      return false;
+    }
+  },
+
   /** ****************************************************************
    * Dremio Driver                                                   *
    ***************************************************************** */

packages/cubejs-pinot-driver/src/PinotDriver.ts

@@ -33,6 +33,7 @@ export type PinotDriverConfiguration = {
   ssl?: string | TLSConnectionOptions;
   dataSource?: string;
   queryTimeout?: number;
+  nullHandling?: boolean;
 };
 
 type AuthorizationHeaders = {
@@ -108,6 +109,7 @@ export class PinotDriver extends BaseDriver implements DriverInterface {
         : undefined,
       authToken: getEnv('pinotAuthToken', { dataSource }),
       ssl: this.getSslOptions(dataSource),
+      nullHandling: getEnv('pinotNullHandling', { dataSource }),
       queryTimeout: getEnv('dbQueryTimeout', { dataSource }),
       ...config
     };
@@ -167,7 +169,7 @@ export class PinotDriver extends BaseDriver implements DriverInterface {
       }),
       body: JSON.stringify({
         sql: query,
-        queryOptions: `useMultistageEngine=true;enableNullHandling=true;timeoutMs=${this.config.queryTimeout}`
+        queryOptions: `useMultistageEngine=true;enableNullHandling=${this.config.nullHandling};timeoutMs=${this.config.queryTimeout}`
       })
     });