in flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/reader/CassandraRecordEmitter.java [113:126]
public Iterator<Row> iterator() {
return new Iterator<Row>() {
@Override
public boolean hasNext() {
return true;
}
@Override
public Row next() {
return row;
}
};
}