A B C D E G H I M N O P R S T U V W

A

add(DeleteRequest) - Method in class org.apache.streams.elasticsearch.ElasticsearchPersistDeleter

Enqueue DeleteRequest.

add(UpdateRequest) - Method in class org.apache.streams.elasticsearch.ElasticsearchPersistUpdater

Enqueue UpdateRequest.

add(String, String, String, String, String) - Method in class org.apache.streams.elasticsearch.ElasticsearchPersistWriter

add based on supplied parameters.

add(String, String, String, String, String, String, String) - Method in class org.apache.streams.elasticsearch.ElasticsearchPersistWriter

add based on supplied parameters.

add(IndexRequest) - Method in class org.apache.streams.elasticsearch.ElasticsearchPersistWriter

addPercolateRule(PercolateTagProcessor.PercolateQueryBuilder, String) - Method in class org.apache.streams.elasticsearch.processor.PercolateTagProcessor

affectedIndexes - Variable in class org.apache.streams.elasticsearch.ElasticsearchPersistWriter

appendMatches(ArrayNode, Activity) - Method in class org.apache.streams.elasticsearch.processor.PercolateTagProcessor

appendMetadata(StreamsDatum) - Method in class org.apache.streams.elasticsearch.ElasticsearchPersistWriter

asMap(JsonNode) - Static method in class org.apache.streams.elasticsearch.ElasticsearchMetadataUtil

get JsonNode as Map.

B

bulkRequest - Variable in class org.apache.streams.elasticsearch.ElasticsearchPersistWriter

C

calcNext() - Method in class org.apache.streams.elasticsearch.ElasticsearchQuery

shift to next page of scroll.

checkForFlush() - Method in class org.apache.streams.elasticsearch.ElasticsearchPersistWriter

checkIndexImplications(String) - Method in class org.apache.streams.elasticsearch.ElasticsearchPersistWriter

cleanUp() - Method in class org.apache.streams.elasticsearch.ElasticsearchPersistReader

cleanUp() - Method in class org.apache.streams.elasticsearch.ElasticsearchPersistWriter

cleanUp() - Method in class org.apache.streams.elasticsearch.ElasticsearchQuery

cleanUp() - Method in class org.apache.streams.elasticsearch.processor.DatumFromMetadataAsDocumentProcessor

cleanUp() - Method in class org.apache.streams.elasticsearch.processor.DatumFromMetadataProcessor

cleanUp() - Method in class org.apache.streams.elasticsearch.processor.DocumentToMetadataProcessor

cleanUp() - Method in class org.apache.streams.elasticsearch.processor.MetadataFromDocumentProcessor

cleanUp() - Method in class org.apache.streams.elasticsearch.processor.PercolateTagProcessor

client() - Method in class org.apache.streams.elasticsearch.ElasticsearchClientManager

config() - Method in class org.apache.streams.elasticsearch.ElasticsearchClientManager

config - Variable in class org.apache.streams.elasticsearch.ElasticsearchPersistWriter

createIndexIfMissing(String) - Method in class org.apache.streams.elasticsearch.ElasticsearchPersistWriter

createIndexIfMissing

createIndexIfMissing(String) - Method in class org.apache.streams.elasticsearch.processor.PercolateTagProcessor

createIndexIfMissing.

currentBatchBytes - Variable in class org.apache.streams.elasticsearch.ElasticsearchPersistWriter

currentBatchItems - Variable in class org.apache.streams.elasticsearch.ElasticsearchPersistWriter

D

DatumFromMetadataAsDocumentProcessor - Class in org.apache.streams.elasticsearch.processor

Uses index and type in metadata map stored in datum document to populate current document into datums.

DatumFromMetadataAsDocumentProcessor() - Constructor for class org.apache.streams.elasticsearch.processor.DatumFromMetadataAsDocumentProcessor

DatumFromMetadataAsDocumentProcessor(ElasticsearchReaderConfiguration) - Constructor for class org.apache.streams.elasticsearch.processor.DatumFromMetadataAsDocumentProcessor

DatumFromMetadataProcessor - Class in org.apache.streams.elasticsearch.processor

Uses index and type in metadata to populate current document into datums.

DatumFromMetadataProcessor() - Constructor for class org.apache.streams.elasticsearch.processor.DatumFromMetadataProcessor

DatumFromMetadataProcessor(ElasticsearchReaderConfiguration) - Constructor for class org.apache.streams.elasticsearch.processor.DatumFromMetadataProcessor

delete(String, String, String) - Method in class org.apache.streams.elasticsearch.ElasticsearchPersistDeleter

Prepare and en-queue @see org.elasticsearch.action.delete.DeleteRequest

deleteOldQueries(String) - Method in class org.apache.streams.elasticsearch.processor.PercolateTagProcessor

delete old queries.

disableRefresh() - Method in class org.apache.streams.elasticsearch.ElasticsearchPersistWriter

docAsJson(Object) - Method in class org.apache.streams.elasticsearch.ElasticsearchPersistWriter

DocumentToMetadataProcessor - Class in org.apache.streams.elasticsearch.processor

Moves a json representation of metadata out of the document to the metadata field.

DocumentToMetadataProcessor() - Constructor for class org.apache.streams.elasticsearch.processor.DocumentToMetadataProcessor

E

ElasticsearchClientManager - Class in org.apache.streams.elasticsearch

Wrapper class for multiple

ElasticsearchConfiguration - Class in org.apache.streams.elasticsearch

ElasticsearchConfiguration() - Constructor for class org.apache.streams.elasticsearch.ElasticsearchConfiguration

ElasticsearchMetadataUtil - Class in org.apache.streams.elasticsearch

Utility class for handling Elasticsearch Metadata maps.

ElasticsearchMetadataUtil() - Constructor for class org.apache.streams.elasticsearch.ElasticsearchMetadataUtil

ElasticsearchPersistDeleter - Class in org.apache.streams.elasticsearch

ElasticsearchPersistDeleter deletes documents from elasticsearch.

ElasticsearchPersistDeleter() - Constructor for class org.apache.streams.elasticsearch.ElasticsearchPersistDeleter

ElasticsearchPersistDeleter(ElasticsearchWriterConfiguration) - Constructor for class org.apache.streams.elasticsearch.ElasticsearchPersistDeleter

ElasticsearchPersistReader - Class in org.apache.streams.elasticsearch

ElasticsearchPersistReader reads documents from elasticsearch.

ElasticsearchPersistReader() - Constructor for class org.apache.streams.elasticsearch.ElasticsearchPersistReader

ElasticsearchPersistReader(ElasticsearchReaderConfiguration) - Constructor for class org.apache.streams.elasticsearch.ElasticsearchPersistReader

ElasticsearchPersistReader.ElasticsearchPersistReaderTask - Class in org.apache.streams.elasticsearch

ElasticsearchPersistReaderTask(ElasticsearchPersistReader, ElasticsearchQuery) - Constructor for class org.apache.streams.elasticsearch.ElasticsearchPersistReader.ElasticsearchPersistReaderTask

ElasticsearchPersistUpdater - Class in org.apache.streams.elasticsearch

ElasticsearchPersistUpdater updates documents to elasticsearch.

ElasticsearchPersistUpdater() - Constructor for class org.apache.streams.elasticsearch.ElasticsearchPersistUpdater

ElasticsearchPersistUpdater(ElasticsearchWriterConfiguration) - Constructor for class org.apache.streams.elasticsearch.ElasticsearchPersistUpdater

ElasticsearchPersistWriter - Class in org.apache.streams.elasticsearch

ElasticsearchPersistUpdater updates documents to elasticsearch.

ElasticsearchPersistWriter() - Constructor for class org.apache.streams.elasticsearch.ElasticsearchPersistWriter

ElasticsearchPersistWriter(ElasticsearchWriterConfiguration) - Constructor for class org.apache.streams.elasticsearch.ElasticsearchPersistWriter

ElasticsearchPersistWriter(ElasticsearchWriterConfiguration, ElasticsearchClientManager) - Constructor for class org.apache.streams.elasticsearch.ElasticsearchPersistWriter

ElasticsearchPersistWriter constructor.

ElasticsearchQuery - Class in org.apache.streams.elasticsearch

Helper for building, querying, and paging an elasticsearch query.

ElasticsearchQuery() - Constructor for class org.apache.streams.elasticsearch.ElasticsearchQuery

ElasticsearchQuery constructor - resolves ElasticsearchReaderConfiguration from JVM 'elasticsearch'.

ElasticsearchQuery(ElasticsearchReaderConfiguration) - Constructor for class org.apache.streams.elasticsearch.ElasticsearchQuery

ElasticsearchQuery constructor - uses provided ElasticsearchReaderConfiguration.

ElasticsearchReaderConfiguration - Class in org.apache.streams.elasticsearch

ElasticsearchReaderConfiguration() - Constructor for class org.apache.streams.elasticsearch.ElasticsearchReaderConfiguration

ElasticsearchWriterConfiguration - Class in org.apache.streams.elasticsearch

ElasticsearchWriterConfiguration() - Constructor for class org.apache.streams.elasticsearch.ElasticsearchWriterConfiguration

equals(Object) - Method in class org.apache.streams.elasticsearch.ElasticsearchConfiguration

equals(Object) - Method in class org.apache.streams.elasticsearch.ElasticsearchReaderConfiguration

equals(Object) - Method in class org.apache.streams.elasticsearch.ElasticsearchWriterConfiguration

equals(Object) - Method in class org.apache.streams.elasticsearch.Tags

execute(Object) - Method in class org.apache.streams.elasticsearch.ElasticsearchQuery

execute ElasticsearchQuery.

G

getActivePercolateTags(String) - Method in class org.apache.streams.elasticsearch.processor.PercolateTagProcessor

get active percolate tags.

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

getClusterName() - Method in class org.apache.streams.elasticsearch.ElasticsearchConfiguration

Cluster Name

getConfig() - Method in class org.apache.streams.elasticsearch.processor.PercolateTagProcessor

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

get id to use based on supplied parameters.

getId(Map<String, Object>) - Static method in class org.apache.streams.elasticsearch.ElasticsearchMetadataUtil

get id to use based on supplied parameters.

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

get Index to use based on supplied parameters.

getIndex(Map<String, Object>, ElasticsearchReaderConfiguration) - Static method in class org.apache.streams.elasticsearch.ElasticsearchMetadataUtil

get Index to use based on supplied parameters.

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

getInstance(ElasticsearchConfiguration) - Static method in class org.apache.streams.elasticsearch.ElasticsearchClientManager

getManager() - Method in class org.apache.streams.elasticsearch.processor.PercolateTagProcessor

getMaxTimeBetweenFlushMs() - Method in class org.apache.streams.elasticsearch.ElasticsearchWriterConfiguration

Max time between flush (ms)

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

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

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

get Type to use based on supplied parameters.

getType(Map<String, Object>, ElasticsearchReaderConfiguration) - Static method in class org.apache.streams.elasticsearch.ElasticsearchMetadataUtil

get Type to use based on supplied parameters.

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

H

hashCode() - Method in class org.apache.streams.elasticsearch.ElasticsearchConfiguration

hashCode() - Method in class org.apache.streams.elasticsearch.ElasticsearchReaderConfiguration

hashCode() - Method in class org.apache.streams.elasticsearch.ElasticsearchWriterConfiguration

hashCode() - Method in class org.apache.streams.elasticsearch.Tags

hasNext() - Method in class org.apache.streams.elasticsearch.ElasticsearchQuery

hasRecords() - Method in class org.apache.streams.elasticsearch.ElasticsearchQuery

I

inQueue - Variable in class org.apache.streams.elasticsearch.processor.PercolateTagProcessor

isCompleted() - Method in class org.apache.streams.elasticsearch.ElasticsearchQuery

isConnected() - Method in class org.apache.streams.elasticsearch.ElasticsearchPersistWriter

isRunning() - Method in class org.apache.streams.elasticsearch.ElasticsearchPersistReader

iterator() - Method in class org.apache.streams.elasticsearch.ElasticsearchQuery

M

manager - Variable in class org.apache.streams.elasticsearch.ElasticsearchPersistWriter

MetadataFromDocumentProcessor - Class in org.apache.streams.elasticsearch.processor

Examines document to derive metadata fields.

MetadataFromDocumentProcessor() - Constructor for class org.apache.streams.elasticsearch.processor.MetadataFromDocumentProcessor

N

next() - Method in class org.apache.streams.elasticsearch.ElasticsearchQuery

numOfPercolateRules() - Method in class org.apache.streams.elasticsearch.processor.PercolateTagProcessor

O

OBJECT_MAPPER - Static variable in class org.apache.streams.elasticsearch.ElasticsearchPersistWriter

org.apache.streams.elasticsearch - package org.apache.streams.elasticsearch

org.apache.streams.elasticsearch.processor - package org.apache.streams.elasticsearch.processor

outQueue - Variable in class org.apache.streams.elasticsearch.processor.PercolateTagProcessor

P

PercolateQueryBuilder(String, String, String) - Constructor for class org.apache.streams.elasticsearch.processor.PercolateTagProcessor.PercolateQueryBuilder

PercolateQueryBuilder constructor.

PercolateTagProcessor - Class in org.apache.streams.elasticsearch.processor

References: Some helpful references to help Purpose URL ------------- ---------------------------------------------------------------- [Status Codes] http://www.w3.org/Protocols/rfc2616/rfc2616-sec10.html [Test Cases] http://greenbytes.de/tech/tc/httpredirects/ [t.co behavior] https://dev.twitter.com/docs/tco-redirection-behavior

PercolateTagProcessor(ElasticsearchWriterConfiguration) - Constructor for class org.apache.streams.elasticsearch.processor.PercolateTagProcessor

PercolateTagProcessor(ElasticsearchWriterConfiguration, String) - Constructor for class org.apache.streams.elasticsearch.processor.PercolateTagProcessor

PercolateTagProcessor.FilterLevel - Enum in org.apache.streams.elasticsearch.processor

PercolateTagProcessor.PercolateQueryBuilder - Class in org.apache.streams.elasticsearch.processor

persistQueue - Variable in class org.apache.streams.elasticsearch.ElasticsearchPersistReader

prepare(Object) - Method in class org.apache.streams.elasticsearch.ElasticsearchPersistReader

prepare(Object) - Method in class org.apache.streams.elasticsearch.ElasticsearchPersistWriter

prepare(Object) - Method in class org.apache.streams.elasticsearch.processor.DatumFromMetadataAsDocumentProcessor

prepare(Object) - Method in class org.apache.streams.elasticsearch.processor.DatumFromMetadataProcessor

prepare(Object) - Method in class org.apache.streams.elasticsearch.processor.DocumentToMetadataProcessor

prepare(Object) - Method in class org.apache.streams.elasticsearch.processor.MetadataFromDocumentProcessor

prepare(Object) - Method in class org.apache.streams.elasticsearch.processor.PercolateTagProcessor

process(StreamsDatum) - Method in class org.apache.streams.elasticsearch.processor.DatumFromMetadataAsDocumentProcessor

process(StreamsDatum) - Method in class org.apache.streams.elasticsearch.processor.DatumFromMetadataProcessor

process(StreamsDatum) - Method in class org.apache.streams.elasticsearch.processor.DocumentToMetadataProcessor

process(StreamsDatum) - Method in class org.apache.streams.elasticsearch.processor.MetadataFromDocumentProcessor

process(StreamsDatum) - Method in class org.apache.streams.elasticsearch.processor.PercolateTagProcessor

R

readAll() - Method in class org.apache.streams.elasticsearch.ElasticsearchPersistReader

readCurrent() - Method in class org.apache.streams.elasticsearch.ElasticsearchPersistReader

readNew(BigInteger) - Method in class org.apache.streams.elasticsearch.ElasticsearchPersistReader

readRange(DateTime, DateTime) - Method in class org.apache.streams.elasticsearch.ElasticsearchPersistReader

remove() - Method in class org.apache.streams.elasticsearch.ElasticsearchQuery

removeOldTags(Set<String>, String) - Method in class org.apache.streams.elasticsearch.processor.PercolateTagProcessor

Attempt to removeOldTags.

run() - Method in class org.apache.streams.elasticsearch.ElasticsearchPersistReader.ElasticsearchPersistReaderTask

S

setAdditionalProperty(String, Object) - Method in class org.apache.streams.elasticsearch.ElasticsearchConfiguration

setAdditionalProperty(String, Object) - Method in class org.apache.streams.elasticsearch.ElasticsearchReaderConfiguration

setAdditionalProperty(String, Object) - Method in class org.apache.streams.elasticsearch.ElasticsearchWriterConfiguration

setAdditionalProperty(String, Object) - Method in class org.apache.streams.elasticsearch.Tags

setBatchBytes(Long) - Method in class org.apache.streams.elasticsearch.ElasticsearchWriterConfiguration

Number of bytes before flush

setBatchSize(int) - Method in class org.apache.streams.elasticsearch.ElasticsearchQuery

setBatchSize(Long) - Method in class org.apache.streams.elasticsearch.ElasticsearchWriterConfiguration

Item Count before flush

setBulk(Boolean) - Method in class org.apache.streams.elasticsearch.ElasticsearchWriterConfiguration

Index in large or small batches

setCleanupTags(Boolean) - Method in class org.apache.streams.elasticsearch.ElasticsearchWriterConfiguration

Whether to remove _percolator rules on shutdown

setClusterName(String) - Method in class org.apache.streams.elasticsearch.ElasticsearchConfiguration

Cluster Name

setConfig(ElasticsearchWriterConfiguration) - Method in class org.apache.streams.elasticsearch.processor.PercolateTagProcessor

setFlushThreasholdMaxTime(long) - Method in class org.apache.streams.elasticsearch.ElasticsearchPersistWriter

setFlushThresholdBytes(long) - Method in class org.apache.streams.elasticsearch.ElasticsearchPersistWriter

setFlushThresholdRecords(long) - Method in class org.apache.streams.elasticsearch.ElasticsearchPersistWriter

setForceUseConfig(Boolean) - Method in class org.apache.streams.elasticsearch.ElasticsearchWriterConfiguration

Whether or not we force the values that are set in the configuration

setHosts(List<String>) - Method in class org.apache.streams.elasticsearch.ElasticsearchConfiguration

Elasticsearch Hosts

setIndex(String) - Method in class org.apache.streams.elasticsearch.ElasticsearchWriterConfiguration

Index to write to

setIndexes(List<String>) - Method in class org.apache.streams.elasticsearch.ElasticsearchReaderConfiguration

Indexes to read from

setManager(ElasticsearchClientManager) - Method in class org.apache.streams.elasticsearch.processor.PercolateTagProcessor

setMaxTimeBetweenFlushMs(Long) - Method in class org.apache.streams.elasticsearch.ElasticsearchWriterConfiguration

Max time between flush (ms)

setPort(Long) - Method in class org.apache.streams.elasticsearch.ElasticsearchConfiguration

Elasticsearch Transport API port

setQueryBuilder(QueryBuilder) - Method in class org.apache.streams.elasticsearch.ElasticsearchQuery

setRefresh(Boolean) - Method in class org.apache.streams.elasticsearch.ElasticsearchWriterConfiguration

Whether to refresh during cleanup

setReplaceTags(Boolean) - Method in class org.apache.streams.elasticsearch.ElasticsearchWriterConfiguration

Whether to overwrite _percolator rules on startup

setScript(String) - Method in class org.apache.streams.elasticsearch.ElasticsearchWriterConfiguration

Script to execute during index

setScrollTimeout(String) - Method in class org.apache.streams.elasticsearch.ElasticsearchQuery

setScrollTimeout(String) - Method in class org.apache.streams.elasticsearch.ElasticsearchReaderConfiguration

Scroll Timeout (JodaTime)

setSearch(Map) - Method in class org.apache.streams.elasticsearch.ElasticsearchReaderConfiguration

Search definition

setTags(Tags) - Method in class org.apache.streams.elasticsearch.ElasticsearchWriterConfiguration

Tags to apply during index

setType(String) - Method in class org.apache.streams.elasticsearch.ElasticsearchWriterConfiguration

Type to write as

setTypes(List<String>) - Method in class org.apache.streams.elasticsearch.ElasticsearchReaderConfiguration

Types to read from

setVeryLargeBulk(boolean) - Method in class org.apache.streams.elasticsearch.ElasticsearchPersistWriter

shutdownAndAwaitTermination(ExecutorService) - Method in class org.apache.streams.elasticsearch.ElasticsearchPersistReader

startStream() - Method in class org.apache.streams.elasticsearch.ElasticsearchPersistReader

STREAMS_ID - Static variable in class org.apache.streams.elasticsearch.ElasticsearchPersistReader

STREAMS_ID - Static variable in class org.apache.streams.elasticsearch.ElasticsearchPersistWriter

STREAMS_ID - Static variable in class org.apache.streams.elasticsearch.processor.MetadataFromDocumentProcessor

STREAMS_ID - Static variable in class org.apache.streams.elasticsearch.processor.PercolateTagProcessor

T

Tags - Class in org.apache.streams.elasticsearch

Tags to apply during index

Tags() - Constructor for class org.apache.streams.elasticsearch.Tags

TAGS_EXTENSION - Static variable in class org.apache.streams.elasticsearch.processor.PercolateTagProcessor

toString() - Method in class org.apache.streams.elasticsearch.ElasticsearchConfiguration

toString() - Method in class org.apache.streams.elasticsearch.ElasticsearchReaderConfiguration

toString() - Method in class org.apache.streams.elasticsearch.ElasticsearchWriterConfiguration

toString() - Method in class org.apache.streams.elasticsearch.Tags

U

update(String, String, String, String, String, String) - Method in class org.apache.streams.elasticsearch.ElasticsearchPersistUpdater

Prepare and en-queue.

usePercolateField - Variable in class org.apache.streams.elasticsearch.processor.PercolateTagProcessor

V

valueOf(String) - Static method in enum org.apache.streams.elasticsearch.processor.PercolateTagProcessor.FilterLevel

Returns the enum constant of this type with the specified name.

values() - Static method in enum org.apache.streams.elasticsearch.processor.PercolateTagProcessor.FilterLevel

Returns an array containing the constants of this enum type, in the order they are declared.

W

withAdditionalProperty(String, Object) - Method in class org.apache.streams.elasticsearch.ElasticsearchConfiguration

withAdditionalProperty(String, Object) - Method in class org.apache.streams.elasticsearch.ElasticsearchReaderConfiguration

withAdditionalProperty(String, Object) - Method in class org.apache.streams.elasticsearch.ElasticsearchWriterConfiguration

withAdditionalProperty(String, Object) - Method in class org.apache.streams.elasticsearch.Tags

withBatchBytes(Long) - Method in class org.apache.streams.elasticsearch.ElasticsearchWriterConfiguration

withBatchSize(Long) - Method in class org.apache.streams.elasticsearch.ElasticsearchWriterConfiguration

withBulk(Boolean) - Method in class org.apache.streams.elasticsearch.ElasticsearchWriterConfiguration

withCleanupTags(Boolean) - Method in class org.apache.streams.elasticsearch.ElasticsearchWriterConfiguration

withClusterName(String) - Method in class org.apache.streams.elasticsearch.ElasticsearchConfiguration

withForceUseConfig(Boolean) - Method in class org.apache.streams.elasticsearch.ElasticsearchWriterConfiguration

withHosts(List<String>) - Method in class org.apache.streams.elasticsearch.ElasticsearchConfiguration

withIndex(String) - Method in class org.apache.streams.elasticsearch.ElasticsearchWriterConfiguration

withIndexes(List<String>) - Method in class org.apache.streams.elasticsearch.ElasticsearchReaderConfiguration

withMaxTimeBetweenFlushMs(Long) - Method in class org.apache.streams.elasticsearch.ElasticsearchWriterConfiguration

withPort(Long) - Method in class org.apache.streams.elasticsearch.ElasticsearchConfiguration

withRefresh(Boolean) - Method in class org.apache.streams.elasticsearch.ElasticsearchWriterConfiguration

withReplaceTags(Boolean) - Method in class org.apache.streams.elasticsearch.ElasticsearchWriterConfiguration

withScript(String) - Method in class org.apache.streams.elasticsearch.ElasticsearchWriterConfiguration

withScrollTimeout(String) - Method in class org.apache.streams.elasticsearch.ElasticsearchReaderConfiguration

withSearch(Map) - Method in class org.apache.streams.elasticsearch.ElasticsearchReaderConfiguration

withTags(Tags) - Method in class org.apache.streams.elasticsearch.ElasticsearchWriterConfiguration

withType(String) - Method in class org.apache.streams.elasticsearch.ElasticsearchWriterConfiguration

withTypes(List<String>) - Method in class org.apache.streams.elasticsearch.ElasticsearchReaderConfiguration

write(StreamsDatum) - Method in class org.apache.streams.elasticsearch.ElasticsearchPersistDeleter

write(StreamsDatum) - Method in class org.apache.streams.elasticsearch.ElasticsearchPersistReader

write(StreamsDatum) - Method in class org.apache.streams.elasticsearch.ElasticsearchPersistUpdater

write(StreamsDatum) - Method in class org.apache.streams.elasticsearch.ElasticsearchPersistWriter

writePercolateRules() - Method in class org.apache.streams.elasticsearch.processor.PercolateTagProcessor

A B C D E G H I M N O P R S T U V W