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

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

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

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

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

B

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

C

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

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

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

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

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

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(Config) - 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(Config) - 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

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

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

ElasticsearchClient - Class in org.apache.streams.elasticsearch

ElasticsearchClient(Client, Version) - Constructor for class org.apache.streams.elasticsearch.ElasticsearchClient

ElasticsearchClientManager - Class in org.apache.streams.elasticsearch

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

ElasticsearchMetadataUtil - Class in org.apache.streams.elasticsearch

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

ElasticsearchPersistDeleter - Class in org.apache.streams.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() - 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() - 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

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

ElasticsearchQuery - Class in org.apache.streams.elasticsearch

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

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

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

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

G

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

getVersion() - Method in class org.apache.streams.elasticsearch.ElasticsearchClient

H

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

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

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

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

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

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

refresh(String[]) - Method in class org.apache.streams.elasticsearch.ElasticsearchClientManager

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

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

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

S

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

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

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

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

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

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

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

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

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

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

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

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

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

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_EXTENSION - Variable in class org.apache.streams.elasticsearch.processor.PercolateTagProcessor

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

U

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

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

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