- All Superinterfaces:
- ProcessFunction<JsonNode,java.lang.String>, java.io.Serializable, SerializableFunction<JsonNode,java.lang.String>
- Enclosing class:
- ElasticsearchIO.Write
public static interface ElasticsearchIO.Write.FieldValueExtractFn
extends SerializableFunction<JsonNode,java.lang.String>
Interface allowing a specific field value to be returned from a parsed JSON document. This is
used for using explicit document ids, and for dynamic routing (index/Type) on a document
basis. A null response will result in default behaviour and an exception will be propagated
as a failure.