- getActivePercolateTags(String) - Method in class org.apache.streams.elasticsearch.processor.PercolateTagProcessor
-
- getAdditionalProperties() - Method in class org.apache.streams.elasticsearch.ElasticsearchConfiguration
-
- getAdditionalProperties() - Method in class org.apache.streams.elasticsearch.ElasticsearchReaderConfiguration
-
- getAdditionalProperties() - Method in class org.apache.streams.elasticsearch.ElasticsearchWriterConfiguration
-
- getAdditionalProperties() - Method in class org.apache.streams.elasticsearch.Tags
-
- getAffectedIndexes() - Method in class org.apache.streams.elasticsearch.ElasticsearchPersistWriter
-
- getBatchBytes() - Method in class org.apache.streams.elasticsearch.ElasticsearchWriterConfiguration
-
Number of bytes before flush
- getBatchesResponded() - Method in class org.apache.streams.elasticsearch.ElasticsearchPersistWriter
-
- getBatchesSent() - Method in class org.apache.streams.elasticsearch.ElasticsearchPersistWriter
-
- getBatchSize() - Method in class org.apache.streams.elasticsearch.ElasticsearchWriterConfiguration
-
Item Count before flush
- getBulk() - Method in class org.apache.streams.elasticsearch.ElasticsearchWriterConfiguration
-
Index in large or small batches
- getCleanupTags() - Method in class org.apache.streams.elasticsearch.ElasticsearchWriterConfiguration
-
Whether to remove _percolator rules on shutdown
- getClient() - Method in class org.apache.streams.elasticsearch.ElasticsearchClient
-
- getClient() - Method in class org.apache.streams.elasticsearch.ElasticsearchClientManager
-
***********************************************************************************
Get the Client for this return, it is actually a transport client, but it is much
easier to work with the generic object as this interface likely won't change from
elasticsearch.
- getClient(String) - Method in class org.apache.streams.elasticsearch.ElasticsearchClientManager
-
- getClusterName() - Method in class org.apache.streams.elasticsearch.ElasticsearchConfiguration
-
Cluster Name
- getConfig() - Method in class org.apache.streams.elasticsearch.processor.PercolateTagProcessor
-
- getDatumStatusCounter() - Method in class org.apache.streams.elasticsearch.ElasticsearchPersistWriter
-
- getElasticsearchConfiguration() - Method in class org.apache.streams.elasticsearch.ElasticsearchClientManager
-
- getFlushThreasholdMaxTime() - Method in class org.apache.streams.elasticsearch.ElasticsearchPersistWriter
-
- getFlushThresholdBytes() - Method in class org.apache.streams.elasticsearch.ElasticsearchPersistWriter
-
- getFlushThresholdsRecords() - Method in class org.apache.streams.elasticsearch.ElasticsearchPersistWriter
-
- getForceUseConfig() - Method in class org.apache.streams.elasticsearch.ElasticsearchWriterConfiguration
-
Whether or not we force the values that are set in the configuration
- getHitCount() - Method in class org.apache.streams.elasticsearch.ElasticsearchQuery
-
- getHosts() - Method in class org.apache.streams.elasticsearch.ElasticsearchConfiguration
-
Elasticsearch Hosts
- getId(StreamsDatum) - Static method in class org.apache.streams.elasticsearch.ElasticsearchMetadataUtil
-
- getId(Map<String, Object>) - Static method in class org.apache.streams.elasticsearch.ElasticsearchMetadataUtil
-
- getId() - Method in class org.apache.streams.elasticsearch.ElasticsearchPersistDeleter
-
- getId() - Method in class org.apache.streams.elasticsearch.ElasticsearchPersistReader
-
- getId() - Method in class org.apache.streams.elasticsearch.ElasticsearchPersistUpdater
-
- getId() - Method in class org.apache.streams.elasticsearch.ElasticsearchPersistWriter
-
- getId() - Method in class org.apache.streams.elasticsearch.processor.DatumFromMetadataAsDocumentProcessor
-
- getId() - Method in class org.apache.streams.elasticsearch.processor.DatumFromMetadataProcessor
-
- getId() - Method in class org.apache.streams.elasticsearch.processor.DocumentToMetadataProcessor
-
- getId() - Method in class org.apache.streams.elasticsearch.processor.MetadataFromDocumentProcessor
-
- getId() - Method in class org.apache.streams.elasticsearch.processor.PercolateTagProcessor
-
- getId() - Method in class org.apache.streams.elasticsearch.processor.PercolateTagProcessor.PercolateQueryBuilder
-
- getIndex(Map<String, Object>, ElasticsearchWriterConfiguration) - Static method in class org.apache.streams.elasticsearch.ElasticsearchMetadataUtil
-
- getIndex(Map<String, Object>, ElasticsearchReaderConfiguration) - Static method in class org.apache.streams.elasticsearch.ElasticsearchMetadataUtil
-
- getIndex() - Method in class org.apache.streams.elasticsearch.ElasticsearchWriterConfiguration
-
Index to write to
- getIndexes() - Method in class org.apache.streams.elasticsearch.ElasticsearchReaderConfiguration
-
Indexes to read from
- getManager() - Method in class org.apache.streams.elasticsearch.processor.PercolateTagProcessor
-
- getMaxTimeBetweenFlushMs() - Method in class org.apache.streams.elasticsearch.ElasticsearchWriterConfiguration
-
- getParent(StreamsDatum) - Static method in class org.apache.streams.elasticsearch.ElasticsearchMetadataUtil
-
- getPort() - Method in class org.apache.streams.elasticsearch.ElasticsearchConfiguration
-
Elasticsearch Transport API port
- getProcessorOutputQueue() - Method in class org.apache.streams.elasticsearch.processor.PercolateTagProcessor
-
- getReadCount() - Method in class org.apache.streams.elasticsearch.ElasticsearchQuery
-
- getReadPercent() - Method in class org.apache.streams.elasticsearch.ElasticsearchQuery
-
- getRefresh() - Method in class org.apache.streams.elasticsearch.ElasticsearchWriterConfiguration
-
Whether to refresh during cleanup
- getRemainingCount() - Method in class org.apache.streams.elasticsearch.ElasticsearchQuery
-
- getReplaceTags() - Method in class org.apache.streams.elasticsearch.ElasticsearchWriterConfiguration
-
Whether to overwrite _percolator rules on startup
- getRouting(StreamsDatum) - Static method in class org.apache.streams.elasticsearch.ElasticsearchMetadataUtil
-
- getScript() - Method in class org.apache.streams.elasticsearch.ElasticsearchWriterConfiguration
-
Script to execute during index
- getScrollTimeout() - Method in class org.apache.streams.elasticsearch.ElasticsearchReaderConfiguration
-
Scroll Timeout (JodaTime)
- getSearch() - Method in class org.apache.streams.elasticsearch.ElasticsearchReaderConfiguration
-
Search definition
- getSource() - Method in class org.apache.streams.elasticsearch.processor.PercolateTagProcessor.PercolateQueryBuilder
-
- getStatus() - Method in class org.apache.streams.elasticsearch.ElasticsearchClientManager
-
- getTags() - Method in class org.apache.streams.elasticsearch.ElasticsearchWriterConfiguration
-
Tags to apply during index
- getTotalFailed() - Method in class org.apache.streams.elasticsearch.ElasticsearchPersistWriter
-
- getTotalOk() - Method in class org.apache.streams.elasticsearch.ElasticsearchPersistWriter
-
- getTotalOutstanding() - Method in class org.apache.streams.elasticsearch.ElasticsearchPersistWriter
-
- getTotalSeconds() - Method in class org.apache.streams.elasticsearch.ElasticsearchPersistWriter
-
- getTotalSent() - Method in class org.apache.streams.elasticsearch.ElasticsearchPersistWriter
-
- getTotalSizeInBytes() - Method in class org.apache.streams.elasticsearch.ElasticsearchPersistWriter
-
- getType(Map<String, Object>, ElasticsearchWriterConfiguration) - Static method in class org.apache.streams.elasticsearch.ElasticsearchMetadataUtil
-
- getType(Map<String, Object>, ElasticsearchReaderConfiguration) - Static method in class org.apache.streams.elasticsearch.ElasticsearchMetadataUtil
-
- getType() - Method in class org.apache.streams.elasticsearch.ElasticsearchWriterConfiguration
-
Type to write as
- getTypes() - Method in class org.apache.streams.elasticsearch.ElasticsearchReaderConfiguration
-
Types to read from
- getVersion() - Method in class org.apache.streams.elasticsearch.ElasticsearchClient
-