I'm working with Jdbc input plugin that I use to ingest a table from mysql to elasticsearch.
Now I have a problem. Is it possible to ingest only the new data in Elasticsearch? I'd like to store data in append.
I thought that maybe it's possible with the WHERE closure and timestamp, like example snippet:
For very huge table I enabled paging (jdbc_paging_enabled, jdbc_page_size), then I tracked id (tracking_column) and I put it in WHERE statement (:sql_last_value point to last id).
Apache, Apache Lucene, Apache Hadoop, Hadoop, HDFS and the yellow elephant
logo are trademarks of the
Apache Software Foundation
in the United States and/or other countries.