$linearFill (aggregation)

Comparison of $fill and $linearFill$fill和$linearFill的比较

To fill missing field values using linear interpolation, you can use:要使用线性插值填充缺失的字段值，可以使用：

• The $fill stage with { method: "linear" }.带有{ method: "linear" }的$fill阶段。

  When you use the $fill stage, the field you specify in the output is the same field used as the source data. See Fill Missing Field Values with Linear Interpolation.使用$fill阶段时，在输出中指定的字段与源数据使用的字段相同。请参见使用线性插值填充缺少的字段值。

• The $linearFill operator inside of a $setWindowFields stage.$setWindowFields阶段内的$linearFill运算符。

  When you use the $linearFill operator, you can set values for a different field than the field used as the source data. See Use Multiple Fill Methods in a Single Stage.使用$linearFill运算符时，可以为不同于用作源数据的字段的字段设置值。请参见在单个阶段中使用多种填充方法。

Fill Missing Values with Linear Interpolation用线性插值填充缺失值

To populate the missing price values using linear interpolation, use $linearFill inside of a $setWindowFields stage:要使用线性插值填充缺失的price值，请在$setWindowFields阶段内使用$linearFill：

db.stock.aggregate( [
   {
      $setWindowFields:
         {
            sortBy: { time: 1 },
            output:
               {
                  price: { $linearFill: "$price" }
               }
         }
   }
] )

In the example:在示例中：

• sortBy: { time: 1 } sorts the documents by the time field in ascending order, from earliest to latest.按照time字段从最早到最晚的升序对文档进行排序。
• output specifies:指定：
  • price as the field for which to fill in missing values.作为要填充缺失值的字段。
  • { $linearFill: "$price" } as the value for the missing field. 作为缺失字段的值。$linearFill fills missing price values using linear interpolation based on the surrounding price values in the sequence.使用基于序列中周围price值的线性插值来填充缺失的price值。

Example output:示例输出：

[
   {
      _id: ObjectId("620ad555394d47411658b5ef"),
      time: ISODate("2021-03-08T09:00:00.000Z"),
      price: 500
   },
   {
      _id: ObjectId("620ad555394d47411658b5f0"),
      time: ISODate("2021-03-08T10:00:00.000Z"),
      price: 507.5
   },
   {
      _id: ObjectId("620ad555394d47411658b5f1"),
      time: ISODate("2021-03-08T11:00:00.000Z"),
      price: 515
   },
   {
      _id: ObjectId("620ad555394d47411658b5f2"),
      time: ISODate("2021-03-08T12:00:00.000Z"),
      price: 505
   },
   {
      _id: ObjectId("620ad555394d47411658b5f3"),
      time: ISODate("2021-03-08T13:00:00.000Z"),
      price: 495
   },
   {
      _id: ObjectId("620ad555394d47411658b5f4"),
      time: ISODate("2021-03-08T14:00:00.000Z"),
      price: 485
   }
]

Use Multiple Fill Methods in a Single Stage在单个阶段中使用多种填充方法

When you use the $setWindowFields stage to fill missing values, you can set values for a different field than the field you fill from. 当您使用$setWindowFields阶段来填充缺失的值时，您可以为不同于从中填充的字段的字段设置值。As a result, you can use multiple fill methods in a single $setWindowFields stage and output the results in distinct fields.因此，您可以在单个$setWindowFields阶段中使用多个填充方法，并在不同的字段中输出结果。

The following pipeline populates missing price fields using linear interpolation and the last-observation-carried-forward method:以下管道使用线性插值和最后一次观测结转方法填充缺失的price字段：

db.stock.aggregate( [
   {
      $setWindowFields:
         {
            sortBy: { time: 1 },
            output:
               {
                  linearFillPrice: { $linearFill: "$price" },
                  locfPrice: { $locf: "$price" }
               }
         }
   }
] )

In the example:在示例中：

• sortBy: { time: 1 } sorts the documents by the time field in ascending order, from earliest to latest.按照time字段从最早到最晚的升序对文档进行排序。
• output specifies:指定：
  • linearFillPrice as a target field to be filled.作为要填充的目标字段。
    • { $linearFill: "$price" } is the value for the linearFillPrice field. 是linearFillPrice字段的值。$linearFill fills missing price values using linear interpolation based on the surrounding price values in the sequence.$linearFill使用基于序列中周围price值的线性插值来填充缺失的价格值。
  • locfPrice as a target field to be filled.作为要填充的目标字段。
    • { $locf: "$price" } is the value for the locfPrice field. 是locfPrice字段的值。locf stands for last observation carried forward. 代表最后一次观测。$locf fills missing price values with the value from the previous document in the sequence.用序列中上一个文档的值填充缺少的price值。

Example output:示例输出：

[
  {
    _id: ObjectId("620ad555394d47411658b5ef"),
    time: ISODate("2021-03-08T09:00:00.000Z"),
    price: 500,
    linearFillPrice: 500,
    locfPrice: 500
  },
  {
    _id: ObjectId("620ad555394d47411658b5f0"),
    time: ISODate("2021-03-08T10:00:00.000Z"),
    linearFillPrice: 507.5,
    locfPrice: 500
  },
  {
    _id: ObjectId("620ad555394d47411658b5f1"),
    time: ISODate("2021-03-08T11:00:00.000Z"),
    price: 515,
    linearFillPrice: 515,
    locfPrice: 515
  },
  {
    _id: ObjectId("620ad555394d47411658b5f2"),
    time: ISODate("2021-03-08T12:00:00.000Z"),
    linearFillPrice: 505,
    locfPrice: 515
  },
  {
    _id: ObjectId("620ad555394d47411658b5f3"),
    time: ISODate("2021-03-08T13:00:00.000Z"),
    linearFillPrice: 495,
    locfPrice: 515
  },
  {
    _id: ObjectId("620ad555394d47411658b5f4"),
    time: ISODate("2021-03-08T14:00:00.000Z"),
    price: 485,
    linearFillPrice: 485,
    locfPrice: 485
  }
]