Function schema_builder

python/pathway/internals/schema.py:830–855

(
    columns: dict[str, ColumnDefinition],
    *,
    name: str | None = None,
    properties: SchemaProperties = SchemaProperties(),
    id_dtype: dt.DType = dt.ANY_POINTER,
    id_append_only: bool | None = None,
)

def schema_builder(
    columns: dict[str, ColumnDefinition],
    *,
    name: str | None = None,
    properties: SchemaProperties = SchemaProperties(),
    id_dtype: dt.DType = dt.ANY_POINTER,
    id_append_only: bool | None = None,
) -> type[Schema]:
    if name is None:
        name = "custom_schema(" + str(list(columns.keys())) + ")"

    __annotations = {name: c.dtype or Any for name, c in columns.items()}

    __dict: dict[str, Any] = {
        "__metaclass__": SchemaMetaclass,
        "__annotations__": __annotations,
        **columns,
    }

    return _schema_builder(
        name,
        __dict,
        properties=properties,
        id_dtype=id_dtype,
        id_append_only=id_append_only,
    )


def schema_from_dict(