hongbo-miao/hongbomiao.com

View on GitHub
data-processing/hm-spark/applications/find-taxi-top-routes/src/utils/df.py

Summary

Maintainability
A
0 mins
Test Coverage
import functools

from pyspark.sql import DataFrame


def union_all(*dfs: DataFrame) -> DataFrame:
    return functools.reduce(DataFrame.unionAll, dfs)