ibis.impala.api.ImpalaClient.avro_file

ImpalaClient.avro_file(hdfs_dir, avro_schema, name=None, database=None, external=True, persist=False)

Create a (possibly temporary) table to read a collection of Avro data.

Parameters:

hdfs_dir : string

Absolute HDFS path to directory containing avro files

avro_schema : dict

The Avro schema for the data as a Python dict

name : string, default None

database : string, default None

external : boolean, default True

persist : boolean, default False

Returns:

avro_table : ImpalaTable