C G M O P R S T

C

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

G

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

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

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

T

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

C G M O P R S T