Я хочу загрузить инкрементальные данные в Apache Друид из Postge sql через Spec. Может ли кто-нибудь поделиться примером spe c.
Я нашел ниже logi c для инкрементальной нагрузки:
step1: когда last_update_date = 2019-09-16 00:00:00 и cdc_date = 2011-01-01 00: 00: 00
выберите last_update_date, cdc_date из cds_events.emp_test, где emp_name в ('Moushmi')
Step2: выберите * из cds_events.emp_test, где last_update_date> cdc_date;
Step3: теперь установите cdc_date = 2019-09-16 00: 00: 00
2) обновить набор cds_events.emp_test CDC_DATE = (выбрать max (last_update_date) из cds_events.emp_test);