code: def get_pe(self):
          
          return PE(self.rest_client.make_request(self.pe), self.rest_client)
docs: Get the Streams processing element this operator is executing in.
  
          Returns:
              PE: Processing element for this operator.
  
          .. versionadded:: 1.9