Pipelines via a Java API

Hi!

I'm trying to create a timestamp to attach to any documents that are indexed. I know this is possible in Query DSL via the below set of commands. I cannot find out how to do so through the Java API. Have any of you done this before?

Thanks!

DELETE anindex

PUT _ingest/pipeline/timestamp {
"description" : "describe pipeline",
"processors" : [
{
"set" : {
"field": "timestamp",
"value": "{{_ingest.timestamp}}"
}
}
]
}

PUT anindex
{
"mappings": {
"jeff": {
}
}
}

PUT anindex/jeff/id10?pipeline=timestamp
{
"hi": "jeff"
}

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.