Function create_external_kudu_query

tests/query_test/test_kudu.py:66–75

(db, tbl, kudu_tbl_name, other_props=None)

def create_external_kudu_query(db, tbl, kudu_tbl_name, other_props=None):
  props = {'kudu.table_name': kudu_tbl_name}
  if other_props is not None:
    props.update(other_props)
  props_str = ', '.join(["'{}'='{}'".format(k, v) for k, v in props.items()])
  return (
    """
    CREATE EXTERNAL TABLE {}.{}
    STORED AS KUDU
    TBLPROPERTIES ({})""").format(db, tbl, props_str)


def set_latest_observed_option(vector, kudu_client):