Apurw
Apurw

Reputation: 113

Limit rows while fetching records using QueryDatabase Table using NiFi

I am trying to use QueryDatabase processor using Apache NiFi Is there any way I can limit the records something like : “select * from table limit 100”

Any other processor in NiFi which supports this operation?

Upvotes: 2

Views: 1185

Answers (1)

notNull
notNull

Reputation: 31490

Use ExecuteSQL processor for this case.

  • Configure/Enable DBCP connection pool

  • In SQL select query property value keep your select query

    select * from table limit 100 enter image description here

Now processor runs the configured sql select query and outputs the results of the query as a flowfile in AVRO format

Upvotes: 5

Related Questions