def _query_cassandra(self):
self.hook = CassandraHook(cassandra_conn_id=self.cassandra_conn_id)<EOL>session = self.hook.get_conn()<EOL>cursor = session.execute(self.cql)<EOL>return cursor<EOL>
Queries cassandra and returns a cursor to the results.