class_docstr: Interact with Pinot Broker Query API.
  
  This hook uses standard-SQL endpoint since PQL endpoint is soon to be deprecated.
  https://docs.pinot.apache.org/users/api/querying-pinot-using-standard-sql
docstr: Establish a connection to pinot broker through pinot dbapi.
docstr_tok: ["Establish","a","connection","to","pinot","broker","through","pinot","dbapi","."]
code: def get_conn(self) -> Any:
      """Establish a connection to pinot broker through pinot dbapi."""
      conn = self.get_connection(self.pinot_broker_conn_id)  # type: ignore
  
      pinot_broker_conn = connect(
          host=conn.host,
          port=conn.port,
          path=conn.extra_dejson.get("endpoint", "/query/sql"),
          scheme=conn.extra_dejson.get("schema", "http"),
      )
      self.log.info(
          "Get the connection to pinot broker on %s", conn.host
      )
      return pinot_broker_conn
  
imports: from __future__ import annotations
  import os
  import subprocess
  from typing import TYPE_CHECKING, Any, Iterable, Mapping
  from pinotdb import connect
  from airflow.exceptions import AirflowException
  from airflow.hooks.base import BaseHook
  from airflow.providers.common.sql.hooks.sql import DbApiHook
label_desc: Use image node_id 1 for calling the PinotDbApiHook obj's underlying member method code with example usage: obj.get_conn() and returns: pinot_broker_conn