$locf (aggregation)

項目一覧

定義
構文
動作
例

定義

$locf

バージョン 5.2 で追加。

Last observation carried forward（LOCF）法。ウィンドウ内の null および欠落しているフィールドの値として、フィールドの最後の null 以外の値を設定します。

$locfは$setWindowFieldsステージでのみ使用可能です。

構文

$locf式は次の構文をとります。

{ $locf: <expression> }

式の詳細については、「式演算子」を参照してください。

動作

If a field being filled contains both null and non-null values, $locf sets the null and missing values to the field's last known non-null value according to the sort order specified in $setWindowFields.

null and missing field values that appear before non-null values in the sort order remain null.

If a field being filled contains only null or missing values in a partition, $locf sets the field value to null for that partition.

Comparison of `$fill` and `$locf`

To fill missing field values based on the last observed value in a sequence, you can use:

The $fill stage with { method: "locf" }.
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 Based on the Last Observed Value.
The $locf operator inside of a $setWindowFields stage.
When you use the $locf 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.

例

The examples on this page use a stock collection that contains tracks a single company's stock price at hourly intervals:

db.stock.insertMany( [
   {
      time: ISODate("2021-03-08T09:00:00.000Z"),
      price: 500
   },
   {
      time: ISODate("2021-03-08T10:00:00.000Z"),
   },
   {
      time: ISODate("2021-03-08T11:00:00.000Z"),
      price: 515
   },
   {
      time: ISODate("2021-03-08T12:00:00.000Z")
   },
   {
      time: ISODate("2021-03-08T13:00:00.000Z")
   },
   {
      time: ISODate("2021-03-08T14:00:00.000Z"),
      price: 485
   }
] )

The price field is missing for some of the documents in the collection.

Fill Missing Values with the Last Observed Value

The following example uses the $locf operator to set missing fields to the value from the last-observed non-null value:

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

この例では、次のことが行われます。

sortBy: { time: 1 } は、各パーティション内のドキュメントを time を基準に昇順（1）にソートするため、最も古い time が最初になります。
For documents where the price field is missing, the $locf operator sets the price to the last-observed value in the sequence.

出力例:

[
  {
    _id: ObjectId("62169b65394d47411658b5f5"),
    time: ISODate("2021-03-08T09:00:00.000Z"),
    price: 500
  },
  {
    _id: ObjectId("62169b65394d47411658b5f6"),
    time: ISODate("2021-03-08T10:00:00.000Z"),
    price: 500
  },
  {
    _id: ObjectId("62169b65394d47411658b5f7"),
    time: ISODate("2021-03-08T11:00:00.000Z"),
    price: 515
  },
  {
    _id: ObjectId("62169b65394d47411658b5f8"),
    time: ISODate("2021-03-08T12:00:00.000Z"),
    price: 515
  },
  {
    _id: ObjectId("62169b65394d47411658b5f9"),
    time: ISODate("2021-03-08T13:00:00.000Z"),
    price: 515
  },
  {
    _id: ObjectId("62169b65394d47411658b5fa"),
    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. As a result, you can use multiple fill methods in a single $setWindowFields stage and output the results in distinct fields.

The following pipeline populates missing price fields using linear interpolation and the last-observation-carried-forward method:

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