apache / arrow-datafusion-python

Unit Size

The distribution of size of units (measured in lines of code).

Longest Units

Top 50 longest units

Unit	# lines	McCabe index	# params
fn execute() in src/dataset_exec.rs	52	1	3
fn new() in src/store.rs	50	7	10
def bench() in benchmarks/tpch/tpch.py	48	9	2
def generate_changelog() in dev/release/generate-changelog.py	42	20	4
fn _types() in src/expr.rs	40	1	1
fn read_csv() in src/context.rs	37	4	9
fn new() in src/store.rs	35	6	7
def to_polars_df() in datafusion/polars.py	34	11	2
fn _internal() in src/lib.rs	34	1	2
fn fmt_as() in src/dataset_exec.rs	32	2	3
fn window() in src/functions.rs	30	2	4
fn register_csv() in src/context.rs	30	3	9
fn join() in src/dataframe.rs	29	1	4
fn register_object_store() in src/context.rs	29	2	4
fn to_variant() in src/expr.rs	28	1	2
fn extract_scalar_list() in src/pyarrow_filter_expression.rs	28	1	2
fn read_json() in src/context.rs	26	3	7
fn create_dataframe() in src/context.rs	24	1	4
fn fmt() in src/expr/join.rs	22	1	2
fn operator_to_py() in src/pyarrow_filter_expression.rs	21	1	2
fn read_avro() in src/context.rs	21	2	6
fn to_rust_function() in src/udf.rs	19	1	1
fn new() in src/udaf.rs	18	1	6
fn __getitem__() in src/dataframe.rs	18	4	2
fn fqn() in src/expr/table_scan.rs	18	1	1
fn read_parquet() in src/context.rs	18	1	7
fn register_parquet() in src/context.rs	17	1	7
fn fmt() in src/expr/explain.rs	16	1	2
fn new() in src/udf.rs	16	1	5
fn new() in src/context.rs	16	3	2
fn __repr__() in src/context.rs	16	1	1
def udaf() in datafusion/__init__.py	15	3	6
fn py_obj_to_scalar_value() in src/config.rs	15	6	2
def print_pulls() in dev/release/generate-changelog.py	14	3	3
def cli() in dev/release/generate-changelog.py	14	2	1
fn update_batch() in src/udaf.rs	14	1	2
fn merge_batch() in src/udaf.rs	14	1	2
fn new() in src/store.rs	14	2	1
fn new() in src/store.rs	14	2	2
fn fmt() in src/expr/like.rs	14	1	2
fn fmt() in src/expr/like.rs	14	1	2
fn fmt() in src/expr/like.rs	14	1	2
fn fmt() in src/expr/create_memory_table.rs	14	1	2
fn fmt() in src/expr/aggregate.rs	14	1	2
fn from_pylist() in src/context.rs	14	1	4
fn from_pydict() in src/context.rs	14	1	4
fn from_pandas() in src/context.rs	14	1	4
fn fmt() in src/expr/table_scan.rs	13	1	2
fn supports_filter_pushdown() in src/common/schema.rs	13	3	2
fn schema() in src/dataset.rs	13	1	1