def isolate(self):
op = self.topology.graph.addOperator("<STR_LIT>")<EOL>op.addInputPort(outputPort=self.oport)<EOL>oport = op.addOutputPort(schema=self.oport.schema)<EOL>return Stream(self.topology, oport)<EOL>
Guarantees that the upstream operation will run in a separate processing element from the downstream operation

Returns:
    Stream: Stream whose subsequent immediate processing will occur in a separate processing element.