org.apache.flink.streaming.connectors.elasticsearch2

Interface ElasticsearchSinkFunction<T>

Type Parameters:

T - The type of the element handled by this ElasticsearchSinkFunction

All Superinterfaces:

Function, Serializable

Deprecated.

Deprecated since 1.2, to be removed at 2.0. This class has been deprecated due to package relocation. Please use ElasticsearchSinkFunction instead.

@Deprecated
public interface ElasticsearchSinkFunction<T>
extends Serializable, Function

Method that creates multiple ActionRequests from an element in a Stream.

This is used by ElasticsearchSink to prepare elements for sending them to Elasticsearch.

Example:

					private static class TestElasticSearchSinkFunction implements
						ElasticsearchSinkFunction<Tuple2<Integer, String>> {

					public IndexRequest createIndexRequest(Tuple2<Integer, String> element) {
						Map<String, Object> json = new HashMap<>();
						json.put("data", element.f1);

						return Requests.indexRequest()
							.index("my-index")
							.type("my-type")
							.id(element.f0.toString())
							.source(json);
						}

				public void process(Tuple2<Integer, String> element, RuntimeContext ctx, RequestIndexer indexer) {
					indexer.add(createIndexRequest(element));
				}
		}

 

Method Summary

Modifier and Type	Method and Description
void	process(T element, RuntimeContext ctx, RequestIndexer indexer) Deprecated.

Method Detail

process

void process(T element,
             RuntimeContext ctx,
             RequestIndexer indexer)

Deprecated.