Interface | Description |
---|---|
IAdditionalValue |
The elasticsearch bolt needs to add additional key values at the end of the json document
to insert.
|
Class | Description |
---|---|
ConstantAdditionalValue |
A constant key value
IAdditionalValue . |
DateAdditionalValue |
A small utility builder class to efficiently generate a json line containing
the current time as a correctly formatted string.
|
ElasticBulkRequest |
This class only takes care of executing a single bulk request for the regular
input document.
|
ElasticDocument |
A transient data structure to hold a document in the pipe to be sent to elasticsearch
|
ElasticDocumentBuilder |
A utility class to build the final json document from the fields received in a storm tuple.
|
ElasticErrorBulkRequest |
This class only takes care of executing a single bulk request to reindex error documents.
|
FailureHandler | |
FieldAdditionalValue |
A key value
IAdditionalValue that takes its value from a storm tuple. |
Enum | Description |
---|---|
FailureHandler.FailureAction |
Copyright © 2022. All rights reserved.