Method _with_schema

python/pathway/internals/table.py:2214–2228

Returns updated table with a forced schema on it.

(self, schema: type[Schema])

    @contextualized_operator
    @check_arg_types
    def _with_schema(self, schema: type[Schema]) -> Table:
        """Returns updated table with a forced schema on it."""
        if schema.keys() != self.schema.keys():
            raise ValueError(
                "Table.with_schema() argument has to have the same column names as in the table."
            )
        context = clmn.SetSchemaContext(
            _id_column=self._id_column,
            _new_properties={
                self[name]._to_internal(): schema.column_properties(name)
                for name in self.column_names()
            },
            _id_column_props=schema.__universe_properties__,
        )
        return self._table_with_context(context)

    @trace_user_frame
    @check_arg_types