Method processOnSchedule

extensions/sql/processors/ExecuteSQL.cpp:83–88

}

void ExecuteSQL::processOnSchedule(core::ProcessContext &context) {
  initOutputFormat(context);

  context.getProperty(s_sqlSelectQuery.getName(), sqlSelectQuery_);
  context.getProperty(s_maxRowsPerFlowFile.getName(), max_rows_);
}

void ExecuteSQL::processOnTrigger(core::ProcessSession& session) {
  auto statement = connection_->prepareStatement(sqlSelectQuery_);