OPEN_PARQUET

Load a local parquet file, then return the data as a dataframe. Inputs ------ default: None Params: file_path : File File path to the .parquet file or an URL of a .parquet file. Returns: out : DataFrame DataFrame loaded from .parquet file

Python Code

from os import path

import pandas as pd
from flojoy import DataFrame, File, flojoy


@flojoy(deps={"pyarrow": "12.0.1", "fastparquet": "2023.7.0"})
def OPEN_PARQUET(file_path: File | None = None) -> DataFrame:
    """Load a local parquet file, then return the data as a dataframe.

    Inputs
    ------
    default: None

    Parameters
    ----------
    file_path : File
        File path to the .parquet file or an URL of a .parquet file.

    Returns
    -------
    DataFrame
        DataFrame loaded from .parquet file
    """

    if file_path[-8:] != ".parquet":
        raise ValueError(f"File type {file_path[-8:]} unsupported.")

    if not path.exists(file_path):
        raise ValueError("File path does not exist!")

    read_parquet = pd.read_parquet(file_path)

    return DataFrame(df=read_parquet)

Find this Flojoy Block on GitHub

Example

Having problems with this example app? Join our Discord community and we will help you out!

Press enter or space to select a node.You can then use the arrow keys to move the node around. Press delete to remove it and escape to cancel.

Press enter or space to select an edge. You can then press delete to remove it or escape to cancel.

Download this Flojoy App

In this example, OPEN_PARQUET loads a local file of the .parquet file format