Opensearch dataprepper only sink the event into opensearch if version bigger than stored

OpenSearch
1

Versions (relevant - OpenSearch/Dashboard/Server OS/Browser):
2.10.2 linux

Describe the issue:
I would opensearch dataprepper only sink the event into opensearch if my json content field version is bigger than the value stored in my opensearch.

How should I achieve this goal.

2

Have you thought of something like:

source: 
  if (ctx._source.version == null || params.version > ctx._source.version) {
  ctx._source.version = params.version;
  }

best,
mj

3

where shall I put this? Your answer isn’t related to dataprepper.