Class UpdateElasticsearchEmitter
- java.lang.Object
-
- org.wikimedia.discovery.cirrus.updater.consumer.graph.UpdateElasticsearchEmitter
-
- All Implemented Interfaces:
Serializable
,org.apache.flink.api.common.functions.Function
,org.apache.flink.connector.elasticsearch.sink.ElasticsearchEmitter<org.apache.flink.types.Row>
public class UpdateElasticsearchEmitter extends Object implements org.apache.flink.connector.elasticsearch.sink.ElasticsearchEmitter<org.apache.flink.types.Row>, Serializable
- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description UpdateElasticsearchEmitter(org.apache.flink.api.java.typeutils.RowTypeInfo updateTypeInfo)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
emit(org.apache.flink.types.Row element, org.apache.flink.api.connector.sink2.SinkWriter.Context context, org.apache.flink.connector.elasticsearch.sink.RequestIndexer indexer)
-
-
-
Method Detail
-
emit
public void emit(org.apache.flink.types.Row element, org.apache.flink.api.connector.sink2.SinkWriter.Context context, org.apache.flink.connector.elasticsearch.sink.RequestIndexer indexer)
- Specified by:
emit
in interfaceorg.apache.flink.connector.elasticsearch.sink.ElasticsearchEmitter<org.apache.flink.types.Row>
-
-