def _change_schema(self, schema, action, name=None, func=None):
if self.oport.schema.schema() == schema.schema():<EOL><INDENT>return self<EOL><DEDENT>if func is None:<EOL><INDENT>func = streamsx.topology.functions.identity<EOL><DEDENT>_name = name<EOL>if _name is None:<EOL><INDENT>_name = action <EOL><DEDENT>css = self._map(func, schema, name=_name)<EOL>if self._placeable:<EOL><INDENT>self._colocate(css, action)<EOL><DEDENT>return css<EOL>
Internal method to change a schema.