def __init__(self, rest_client, credentials):
self.rest_client = rest_client<EOL>self._credentials = credentials<EOL>
Args:
    rest_client (_StreamsRestClient): The client used to make the REST call.
    credentials (str): credentials for accessing Streaming Analytics service.