apache / arrow-ballista-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
def main() in dev/release/download-python-wheels.py	83	13	0
def test_get_affected_topics() in ci/detect-changes.py	49	1	0
fn new() in src/executor.rs	33	1	7
fn join() in src/dataframe.rs	31	1	4
fn register_csv() in src/context.rs	31	3	9
def main() in dev/update_ballista_versions.py	29	4	0
fn new() in src/scheduler.rs	27	1	4
def get_affected_topics() in ci/detect-changes.py	26	7	1
fn window() in src/functions.rs	26	1	4
def main() in dev/update_arrow_deps.py	24	5	0
def main() in dev/update_datafusion_versions.py	24	4	0
def run_from_travis() in ci/detect-changes.py	23	7	0
def update_cargo_toml() in dev/update_ballista_versions.py	23	6	2
def get_travis_commit_range() in ci/detect-changes.py	20	3	0
fn to_rust_function() in src/udf.rs	20	1	1
fn new() in src/context.rs	20	1	5
fn new() in src/udaf.rs	18	1	6
fn __getitem__() in src/dataframe.rs	18	4	2
fn new() in src/udf.rs	16	1	5
def udaf() in ballista/__init__.py	15	3	6
def run_cmd() in ci/detect-changes.py	15	2	1
def run_from_github() in ci/detect-changes.py	15	2	0
def update_downstream_versions() in dev/update_datafusion_versions.py	15	6	2
def list_appveyor_affected_files() in ci/detect-changes.py	14	3	0
def update_version_cargo_toml() in dev/update_arrow_deps.py	14	5	2
fn update_batch() in src/udaf.rs	14	1	2
fn merge_batch() in src/udaf.rs	14	1	2
def run_from_appveyor() in ci/detect-changes.py	13	2	0
fn _internal() in src/lib.rs	13	1	2
def udf() in ballista/__init__.py	12	3	5
def update_docker_compose() in dev/update_ballista_versions.py	11	1	2
fn $NAME() in src/functions.rs	11	1	2
fn __richcmp__() in src/expression.rs	11	1	3
fn count_star() in src/functions.rs	10	1	0
fn fmt() in src/errors.rs	10	1	2
fn read_csv() in src/context.rs	10	2	4
def list_travis_affected_files() in ci/detect-changes.py	9	3	0
def update_commit_cargo_toml() in dev/update_arrow_deps.py	9	1	2
def update_docs() in dev/update_datafusion_versions.py	9	1	2
fn order_by() in src/functions.rs	9	1	3
def dump_env_vars() in ci/detect-changes.py	8	5	2
def update_commit_dependencies() in dev/update_arrow_deps.py	8	5	2
def update_datafusion_version() in dev/update_datafusion_versions.py	8	1	2
fn col() in src/functions.rs	8	1	1
fn in_list() in src/functions.rs	8	1	3
fn fmt() in src/errors.rs	8	1	2
fn read_parquet() in src/context.rs	8	2	3
fn read_avro() in src/context.rs	8	2	3
fn explain_string() in src/dataframe.rs	7	1	4
fn $NAME() in src/functions.rs	7	1	1