plugins/tech/cassandra/src/main/java/org/apache/hop/databases/cassandra/spi/CqlRowHandler.java
void newRowQuery(
      ITransform requestingTransform,
      String tableName,
      String cqlQuery,
      String compress,
      String consistencyLevel,
      ILogChannel log)
      throws Exception;
/**
   * Executes a new CQL query and initializes ready for iteration over the results. Closes/discards
   * any previous query.
   *
   * @param requestingTransform the transform that is requesting rows - clients can use this
   *     primarily to check whether the running pipeline has been paused or stopped (via isPaused()
   *     and isStopped())
   * @param tableName the name of the table to execute the query against
   * @param cqlQuery the CQL query to execute
   * @param compress the name of the compression to use (may be null for no compression)
   * @param consistencyLevel the consistency level to use
   * @param log the log to use
   * @throws Exception if a problem occurs
   */
Executes a new CQL query and initializes ready for iteration over the results. Closes/discards
any previous query.


Executes a new CQL query and initializes ready for iteration over the results . Closes / discards any previous query .
void newRowQuery(
      ITransform requestingTransform,
      String tableName,
      String cqlQuery,
      String compress,
      String consistencyLevel,
      ILogChannel log)
      throws Exception;
void newRowQuery ( ITransform requestingTransform , String tableName , String cqlQuery , String compress , String consistencyLevel , ILogChannel log ) throws Exception ;
Executes a new CQL query and initializes ready for iteration over the results.
Executes a new CQL query and initializes ready for iteration over the results .