| 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.