Согласно импортеру jdbc:
Для синхронизации рекомендуется использовать метки времени в формате UTC. В этом примере извлекаются все строки продуктов, которые были добавлены с момента последнего запуска, с использованием столбца mytimestamp с разрешением в миллисекундах:
{
"type" : "jdbc",
"jdbc" : {
"url" : "jdbc:mysql://localhost:3306/test",
"user" : "",
"password" : "",
"sql" : [
{
"statement" : "select * from \"products\" where \"mytimestamp\" > ?",
"parameter" : [ "$metrics.lastexecutionstart" ]
}
],
"index" : "my_jdbc_index",
"type" : "my_jdbc_type"
}
}
Я хочу вводить данные постепенно на основе измененных данных столбца в формате 2015-08-20 14:52:09, также я использую планировщик, который запускается каждую минуту. Я пробовал со значением ключа sql как
"statement" : "select * from \"products\" where \"modifiedDate\" > ?",
Но данные не загружались.
Я что-то упускаю?
