def get_pe(self):
return PE(self.rest_client.make_request(self.pe), self.rest_client)<EOL>
Get the Streams processing element this operator is executing in.

        Returns:
            PE: Processing element for this operator.

        .. versionadded:: 1.9