Function static_table_from_pandas

python/pathway/tests/test_api.py:42–70

(scope, df, ptr_columns=(), legacy=True)

def static_table_from_pandas(scope, df, ptr_columns=(), legacy=True):
    for column in ptr_columns:
        df[column] = df[column].apply(api.unsafe_make_pointer)

    schema = schema_from_pandas(df)

    columns: list[api.ColumnProperties] = []

    for col in schema.columns().values():
        columns.append(
            api.ColumnProperties(
                dtype=col.dtype.to_engine(),
                append_only=col.append_only,
            )
        )

    connector_properties = api.ConnectorProperties(
        unsafe_trusted_ids=True,
        column_properties=columns,
    )

    table = api.static_table_from_pandas(
        scope,
        df,
        connector_properties,
    )
    if legacy:
        table = table_to_legacy(scope, table, len(df.columns))
    return table


def convert_table(scope, table):