java - 一旦通过文件摄取生成段，如何更新德鲁伊指标的值

Question

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
      }
   }
}

现在根据要求，Forecast 的值会发生变化，甚至其他维度也会发生变化。我在看druid update existing data ,却找不到解法。

Answer 1

要更新数据，您需要使用更新后的值为同一时间段的数据重新编制索引。

但在您的情况下，您似乎有新的预测值，因此只需为新的时间间隔摄取新值就应该更新您的指标值。