def viewIdentityFeeder()

in benchmarks/src/gatling/scala/org/apache/polaris/benchmarks/actions/ViewActions.scala [52:72]


  def viewIdentityFeeder(): Feeder[Any] = dp.nAryTree.lastLevelOrdinals.iterator
    .flatMap { namespaceId =>
      val catalogId = 0
      val parentNamespacePath: Seq[String] = dp.nAryTree
        .pathToRoot(namespaceId)
        .map(ordinal => s"NS_$ordinal")
      val positionInLevel = namespaceId - dp.nAryTree.lastLevelOrdinals.head

      Range(0, dp.numViewsPerNs)
        .map { j =>
          // Ensure the view ID matches that of the associated table
          val viewId = positionInLevel * dp.numTablesPerNs + j
          Map(
            "catalogName" -> s"C_$catalogId",
            "parentNamespacePath" -> parentNamespacePath,
            "multipartNamespace" -> parentNamespacePath.mkString("%1F"),
            "viewName" -> s"V_$viewId",
            "viewId" -> viewId
          )
        }
    }