Skip to content

Commit

Permalink
Merge pull request #238 from lichess-org/another-forum-ingestor-impro…
Browse files Browse the repository at this point in the history
…vement

Another forum ingestor improvement
  • Loading branch information
lenguyenthanh committed Jun 19, 2024
2 parents 1a5f0bf + c9f3a56 commit 83ec1c9
Showing 1 changed file with 3 additions and 1 deletion.
4 changes: 3 additions & 1 deletion modules/ingestor/src/main/scala/ingestor.forum.scala
Original file line number Diff line number Diff line change
Expand Up @@ -22,10 +22,12 @@ object ForumIngestor:

private val topicProjection = Projection.include(List("_id", "name"))

private val interestedOperations = List(DELETE, INSERT, UPDATE, REPLACE).map(_.getValue)
private val interestedOperations = List(DELETE, INSERT, REPLACE).map(_.getValue)
private val eventFilter = Filter.in("operationType", interestedOperations)

private val eventProjection = Projection.include(
List(
"operationType",
"clusterTime",
"documentKey._id",
"fullDocument.text",
Expand Down

0 comments on commit 83ec1c9

Please sign in to comment.