keedio / flume-ng-sql-source

Flume Source to import data from SQL Databases
Apache License 2.0
264 stars 164 forks source link

Get lastvalue as Max Timestamp #95

Open ujjwalit opened 4 years ago

ujjwalit commented 4 years ago

Can we have Current Index sqlSourceHelper.setCurrentIndex(Integer.toString((Integer.parseInt(sqlSourceHelper.getCurrentIndex())+ rowsList.size()))) To the Max Value of the given column that is like max timestamp in case of timestamp column