org.apache.flink.connector.elasticsearch.sink

Class MapElasticsearchEmitter

java.lang.Object

org.apache.flink.connector.elasticsearch.sink.MapElasticsearchEmitter

All Implemented Interfaces:

Serializable, Function, ElasticsearchEmitter<Map<String,Object>>

public class MapElasticsearchEmitter
extends Object
implements ElasticsearchEmitter<Map<String,Object>>

A simple ElasticsearchEmitter which is currently used in PyFlink ES connector.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
MapElasticsearchEmitter(String index, String documentType, String idFieldName, boolean isDynamicIndex)

Method Summary

Modifier and Type	Method and Description
void	emit(Map<String,Object> doc, SinkWriter.Context context, RequestIndexer indexer) Process the incoming element to produce multiple ActionRequests.
void	open() Initialization method for the function.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.connector.elasticsearch.sink.ElasticsearchEmitter

close

Constructor Detail

MapElasticsearchEmitter

public MapElasticsearchEmitter(String index,
                               @Nullable
                               String documentType,
                               @Nullable
                               String idFieldName,
                               boolean isDynamicIndex)

Method Detail

open

public void open()
          throws Exception

Description copied from interface: ElasticsearchEmitter

Initialization method for the function. It is called once before the actual working process methods.

Specified by:

open in interface ElasticsearchEmitter<Map<String,Object>>

Throws:

Exception

emit

public void emit(Map<String,Object> doc,
                 SinkWriter.Context context,
                 RequestIndexer indexer)

Description copied from interface: ElasticsearchEmitter

Process the incoming element to produce multiple ActionRequests. The produced requests should be added to the provided RequestIndexer.

Specified by:

emit in interface ElasticsearchEmitter<Map<String,Object>>

Parameters:

doc - incoming element to process

context - to access additional information about the record

indexer - request indexer that ActionRequest should be added to