как обновить значение метрики друида после того, как сегменты сгенерированы при загрузке файла

Осколки источника данных druid в нескольких интервалах (сегментах) загружали файл json. Но как я могу обновить значение метрики и измерения существующих данных? Ожидается некоторая настройка запроса, такая как обновление SQL в формате друида.

Вот пример настройки задачи

{
   "type":"index",
   "spec":{
      "dataSchema":{
         "dataSource":"schema_sample",
         "parser":{
            "type":"string",
            "parseSpec":{
               "format":"json",
               "timestampSpec":{
                  "column":"WeekDate",
                  "format":"auto"
               },
               "dimensionsSpec":{
                  "dimensions":[
                     "_id",
                     "ItemNumber",
                     "MonthNo",
                     "Year",
                     "MonthNo",
                     "CustomerName"
                  ],
                  "dimensionExclusions":[

                  ],
                  "spatialDimensions":[

                  ]
               }
            }
         },
         "metricsSpec":[
            {
               "type":"doubleSum",
               "name":"Forecast",
               "fieldName":"Forecast"
            }
         ],
         "granularitySpec":{
            "type":"uniform",
            "segmentGranularity":"WEEK",
            "queryGranularity":"NONE",
            "intervals":[
               "2014-01-01/2019-12-31"
            ]
         }
      },
      "ioConfig":{
         "type":"index",
         "firehose":{
            "type":"local",
            "baseDir":"quickstart/",
            "filter":"fr_json_data_1k.json"
         }
      },
      "tuningConfig":{
         "type":"index",
         "targetPartitionSize":5000000,
         "maxRowsInMemory":75000
      }
   }
}

Теперь, согласно требованию, изменится значение прогноза или даже другие параметры. Я смотрел друид обновить существующие данные, но не смог найти решение.


linux java olap apache-zookeeper druid
person Amit Sah    schedule 22.12.2017    source источник

Ответы (1)


arrow_upward
0
arrow_downward

для обновления данных вам необходимо повторно проиндексировать данные за тот же период времени с обновленными значениями.

Но в вашем случае кажется, что у вас появятся новые значения прогноза, поэтому простое введение новых значений для нового временного интервала должно обновить значения ваших метрик.

person mdeora    schedule 23.05.2018