प्रोग्रामिंग, सवालों के जवाब में मदद करें / जावा / फ़ाइल इंजेक्शन के माध्यम से उत्पन्न खंडों के बाद ड्रूइड मेट्रिक के मूल्य को कैसे अपडेट करें - जावा, लिनक्स, अपाचे-जुकीपर, ओलाप, ड्रुइड

फाइल इंजेक्शन के माध्यम से उत्पन्न खंडों के बाद ड्रूइड मेट्रिक के मूल्य को कैसे अपडेट करें - जावा, लिनक्स, अपाचे-जुकीपर, ओलाप, ड्रुइड

The ड्र्यूड एक से अधिक अंतराल (सेगमेंट) में डेटा स्रोत का ठीकरा json फ़ाइल । लेकिन मैं मौजूदा डेटा के मेट्रिक "s और आयाम" s मान को कैसे अपडेट कर सकता हूं.ड्र्यूड स्वरूप में 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
}
}
}

अब आवश्यकता के अनुसार, पूर्वानुमान "एस मूल्य बदल जाएगा या यहां तक कि अंय आयामों को भी ।मैं देख रहा था ड्र्यूड अद्यतन मौजूदा डेटा , लेकिन समाधान ढूंढने में असमर्थ ।

उत्तर:

जवाब के लिए 0 № 1

डेटा अद्यतन करने के लिए, आपको अपने डेटा को अद्यतित मानों के साथ एक ही समयावधि के लिए पुन: अनुक्रमित करना होगा ।

लेकिन आपके मामले में, ऐसा लगता है कि आप नए पूर्वानुमान मूल्यों आ रहा है, तो बस नए समय अंतराल के लिए नए मूल्यों घूस अपने मीट्रिक मूल्यों का अद्यतन करना चाहिए ।