def connect(host='localhost', port=21050, database='default', timeout=45,
            use_ssl=False, ca_cert=None, user=None,
            password=None, auth_mechanism='NOSASL',
            kerberos_service_name='impala', pool_size=8, hdfs_client=None):
    params = {
        'host': host,
        'port': port,
        'database': database,
        'timeout': timeout,
        'use_ssl': use_ssl,
        'ca_cert': ca_cert,
        'user': user,
        'password': password,
        'auth_mechanism': auth_mechanism,
        'kerberos_service_name': kerberos_service_name
    }

    con = ImpalaConnection(pool_size=pool_size, **params)
    client = ImpalaClient(con, hdfs_client=hdfs_client)

    if options.default_backend is None:
        options.default_backend = client

    return client
Write the given buffer to this handle.
dataset/ETHPy150Open cloudera/ibis/ibis/impala/api.py/connect--crossover with--dataset/ETHPy150Open nlloyd/SubliminalCollaborator/libs/twisted/internet/iocpreactor/interfaces.py/IWriteHandle.writeToHandle