请描述您的问题
标题:年底大酬宾-腾讯云
地址:https://cloud.tencent.com/act/bargin?utm_source=portal&utm_medium=banner&utm_campaign=bargin&utm_term=1204
浏览器信息
Mozilla/5.0 (Macintosh; Intel Mac OS X 10_12_6) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/63.0.3239.84 Safari/537.36
我目前正在研究一个回归问题,这个问题要求我预测固定资产的成本。为此,我使用了几个变量,并得出了一个预测成本。然而,我的上级希望我将时间作为一个变量纳入回归模型,而我对如何做到这一点感到困惑。我的数据集看起来像这样,不像时间序列数据集。
Name Capacity OEM Country Date of valuation MONTH YEAR Cost
A1 220 JAPAN JAPAN 1/1/2012 1 2012 300,000,000
A2 220
我使用Kafka来处理消息。消息可以分成几个部分(它是一个复合消息)。例如,在流中,我可以有一个被分成三个部分的复合消息。换句话说,它将是Kafka流中的三个记录,但这是一个大消息。我想使用Kafka表在一个Kafka记录中合并复合消息的各个部分。合并后,将在数据库(Postgres)中插入一封邮件。每个部件都有部件数和总部件数。例如,如果我在流中有一条消息的三个部分(三个Kafka记录)-每个部分都有字段total number of part,值为3。
我的理解是,任务在积极的场景中很简单:在表中聚合部件,从表中创建流,并过滤具有等于聚合部件大小和部件总数的记录,映射在一个合并的消息中过滤