Package org.nuxeo.elasticsearch.bulk
Class IndexAction
java.lang.Object
org.nuxeo.elasticsearch.bulk.IndexAction
- All Implemented Interfaces:
StreamProcessorTopology
A Nuxeo Bulk Action to index documents. it decouples the document extraction to build the elasticsearch request and
the indexing.
- Since:
- 10.3
-
Field Summary
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionstatic int
getOptionAsInteger
(Map<String, String> options, String option, int defaultValue) getTopology
(Map<String, String> options) Returns a Stream computation topology.
-
Field Details
-
ACTION_NAME
- See Also:
-
ACTION_FULL_NAME
- See Also:
-
ES_BULK_SIZE_OPTION
- See Also:
-
ES_BULK_SIZE_DEFAULT
public static final int ES_BULK_SIZE_DEFAULT- See Also:
-
ES_BULK_ACTION_OPTION
- See Also:
-
ES_BULK_ACTION_DEFAULT
public static final int ES_BULK_ACTION_DEFAULT- See Also:
-
BULK_FLUSH_INTERVAL_OPTION
- See Also:
-
BULK_FLUSH_INTERVAL_DEFAULT
public static final int BULK_FLUSH_INTERVAL_DEFAULT- See Also:
-
INDEX_UPDATE_ALIAS_PARAM
- See Also:
-
REFRESH_INDEX_PARAM
- See Also:
-
-
Constructor Details
-
IndexAction
public IndexAction()
-
-
Method Details
-
getTopology
Description copied from interface:StreamProcessorTopology
Returns a Stream computation topology.- Specified by:
getTopology
in interfaceStreamProcessorTopology
-
getOptionAsInteger
-