Package | Description |
---|---|
org.apache.streams.elasticsearch | |
org.apache.streams.elasticsearch.processor |
Modifier and Type | Method and Description |
---|---|
ElasticsearchReaderConfiguration |
ElasticsearchReaderConfiguration.withAdditionalProperty(String name,
Object value) |
ElasticsearchReaderConfiguration |
ElasticsearchReaderConfiguration.withIndexes(List<String> indexes) |
ElasticsearchReaderConfiguration |
ElasticsearchReaderConfiguration.withScrollTimeout(String scrollTimeout) |
ElasticsearchReaderConfiguration |
ElasticsearchReaderConfiguration.withSearch(Map Search) |
ElasticsearchReaderConfiguration |
ElasticsearchReaderConfiguration.withTypes(List<String> types) |
Modifier and Type | Method and Description |
---|---|
static String |
ElasticsearchMetadataUtil.getIndex(Map<String,Object> metadata,
ElasticsearchReaderConfiguration config)
get Index to use based on supplied parameters.
|
static String |
ElasticsearchMetadataUtil.getType(Map<String,Object> metadata,
ElasticsearchReaderConfiguration config)
get Type to use based on supplied parameters.
|
Constructor and Description |
---|
ElasticsearchPersistReader(ElasticsearchReaderConfiguration config) |
ElasticsearchQuery(ElasticsearchReaderConfiguration config)
ElasticsearchQuery constructor - uses provided ElasticsearchReaderConfiguration.
|
Constructor and Description |
---|
DatumFromMetadataAsDocumentProcessor(ElasticsearchReaderConfiguration config) |
DatumFromMetadataProcessor(ElasticsearchReaderConfiguration config) |
Copyright © 2018 The Apache Software Foundation. All rights reserved.