Package | Description |
---|---|
org.apache.flink.streaming.connectors.elasticsearch | |
org.apache.flink.streaming.connectors.elasticsearch.util |
Modifier and Type | Method and Description |
---|---|
void |
ActionRequestFailureHandler.onFailure(org.elasticsearch.action.ActionRequest action,
Throwable failure,
int restStatusCode,
RequestIndexer indexer)
Handle a failed
ActionRequest . |
void |
ElasticsearchSinkFunction.process(T element,
RuntimeContext ctx,
RequestIndexer indexer)
Process the incoming element to produce multiple
ActionsRequests . |
Modifier and Type | Method and Description |
---|---|
void |
RetryRejectedExecutionFailureHandler.onFailure(org.elasticsearch.action.ActionRequest action,
Throwable failure,
int restStatusCode,
RequestIndexer indexer) |
void |
NoOpFailureHandler.onFailure(org.elasticsearch.action.ActionRequest action,
Throwable failure,
int restStatusCode,
RequestIndexer indexer) |
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.