@Override
  public void setFetchSize(int rows) throws SQLException {
    this.fetchSize = rows;
    writeStatement.setFetchSize(fetchSize);
    for (Statement readStatement : readStatements) {
      readStatement.setFetchSize(fetchSize);
    }
  }
The implementation of {@link ClusterTestStatement} in cluster test.
integration-test/src/main/java/org/apache/iotdb/itbase/runtime/ClusterTestStatement.java