C E G H M O P R S T W

C

cleanUp() - Method in class org.apache.streams.example.TwitterUserstreamElasticsearch.SetDeleteIdProcessor

E

equals(Object) - Method in class org.apache.streams.example.TwitterUserstreamElasticsearchConfiguration

G

getElasticsearch() - Method in class org.apache.streams.example.TwitterUserstreamElasticsearchConfiguration

(Required)

getId() - Method in class org.apache.streams.example.TwitterUserstreamElasticsearch.SetDeleteIdProcessor

getTwitter() - Method in class org.apache.streams.example.TwitterUserstreamElasticsearchConfiguration

(Required)

H

hashCode() - Method in class org.apache.streams.example.TwitterUserstreamElasticsearchConfiguration

M

main(String[]) - Static method in class org.apache.streams.example.TwitterUserstreamElasticsearch

O

org.apache.streams.example - package org.apache.streams.example

P

prepare(Object) - Method in class org.apache.streams.example.TwitterUserstreamElasticsearch.SetDeleteIdProcessor

process(StreamsDatum) - Method in class org.apache.streams.example.TwitterUserstreamElasticsearch.SetDeleteIdProcessor

R

run() - Method in class org.apache.streams.example.TwitterUserstreamElasticsearch

S

SetDeleteIdProcessor() - Constructor for class org.apache.streams.example.TwitterUserstreamElasticsearch.SetDeleteIdProcessor

setElasticsearch(ElasticsearchWriterConfiguration) - Method in class org.apache.streams.example.TwitterUserstreamElasticsearchConfiguration

(Required)

setTwitter(TwitterStreamConfiguration) - Method in class org.apache.streams.example.TwitterUserstreamElasticsearchConfiguration

(Required)

STREAMS_ID - Static variable in class org.apache.streams.example.TwitterUserstreamElasticsearch

T

toString() - Method in class org.apache.streams.example.TwitterUserstreamElasticsearchConfiguration

TwitterUserstreamElasticsearch - Class in org.apache.streams.example

Example stream that populates elasticsearch with activities from twitter userstream in real-time

TwitterUserstreamElasticsearch() - Constructor for class org.apache.streams.example.TwitterUserstreamElasticsearch

TwitterUserstreamElasticsearch(TwitterUserstreamElasticsearchConfiguration) - Constructor for class org.apache.streams.example.TwitterUserstreamElasticsearch

TwitterUserstreamElasticsearch.SetDeleteIdProcessor - Class in org.apache.streams.example

TwitterUserstreamElasticsearchConfiguration - Class in org.apache.streams.example

TwitterUserstreamElasticsearchConfiguration() - Constructor for class org.apache.streams.example.TwitterUserstreamElasticsearchConfiguration

W

withElasticsearch(ElasticsearchWriterConfiguration) - Method in class org.apache.streams.example.TwitterUserstreamElasticsearchConfiguration

withTwitter(TwitterStreamConfiguration) - Method in class org.apache.streams.example.TwitterUserstreamElasticsearchConfiguration

C E G H M O P R S T W