A B C D E G I L M N O P R S

A

AbstractBackOffStrategy - Class in org.apache.streams.util.api.requests.backoff

AbstractBackOffStrategy(long) - Constructor for class org.apache.streams.util.api.requests.backoff.AbstractBackOffStrategy

A BackOffStrategy that can effectively be used endlessly.

AbstractBackOffStrategy(long, int) - Constructor for class org.apache.streams.util.api.requests.backoff.AbstractBackOffStrategy

A BackOffStrategy that has a limited number of uses before it throws a BackOffException

AbstractOauthToken - Class in org.apache.streams.util.oauth.tokens

AbstractOauthToken() - Constructor for class org.apache.streams.util.oauth.tokens.AbstractOauthToken

addAllTokensToPool(Collection<T>) - Method in class org.apache.streams.util.oauth.tokens.tokenmanager.impl.BasicTokenManger

addAllTokensToPool(Collection<T>) - Method in interface org.apache.streams.util.oauth.tokens.tokenmanager.SimpleTokenManager

Adds a Collection of tokens to the available token pool.

addTokenToPool(T) - Method in class org.apache.streams.util.oauth.tokens.tokenmanager.impl.BasicTokenManger

addTokenToPool(T) - Method in interface org.apache.streams.util.oauth.tokens.tokenmanager.SimpleTokenManager

Adds a token to the available token pool.

B

backOff() - Method in class org.apache.streams.util.api.requests.backoff.AbstractBackOffStrategy

backOff() - Method in interface org.apache.streams.util.api.requests.backoff.BackOffStrategy

Cause the current thread to sleep for an amount of time based on the implemented strategy.

BackOffException - Exception in org.apache.streams.util.api.requests.backoff

Exception that is thrown when a AbstractBackOffStrategy has attempted to backOff() more than the AbstractBackOffStrategy was configured for.

BackOffException() - Constructor for exception org.apache.streams.util.api.requests.backoff.BackOffException

BackOffException(String) - Constructor for exception org.apache.streams.util.api.requests.backoff.BackOffException

BackOffException(int, long) - Constructor for exception org.apache.streams.util.api.requests.backoff.BackOffException

BackOffException(String, int, long) - Constructor for exception org.apache.streams.util.api.requests.backoff.BackOffException

BackOffStrategy - Interface in org.apache.streams.util.api.requests.backoff

BackOffStrategy will cause the current thread to sleep for a specific amount of time.

BasicTokenManger<T> - Class in org.apache.streams.util.oauth.tokens.tokenmanager.impl

Manages a pool of tokens the most basic possible way.

BasicTokenManger() - Constructor for class org.apache.streams.util.oauth.tokens.tokenmanager.impl.BasicTokenManger

BasicTokenManger(Collection<T>) - Constructor for class org.apache.streams.util.oauth.tokens.tokenmanager.impl.BasicTokenManger

C

calculateBackOffTime(int, long) - Method in class org.apache.streams.util.api.requests.backoff.AbstractBackOffStrategy

Calculate the amount of time in milliseconds that the strategy should back off for

calculateBackOffTime(int, long) - Method in class org.apache.streams.util.api.requests.backoff.impl.ConstantTimeBackOffStrategy

calculateBackOffTime(int, long) - Method in class org.apache.streams.util.api.requests.backoff.impl.ExponentialBackOffStrategy

calculateBackOffTime(int, long) - Method in class org.apache.streams.util.api.requests.backoff.impl.LinearTimeBackOffStrategy

cloneBySerialization(T) - Static method in class org.apache.streams.util.SerializationUtil

ComponentUtils - Class in org.apache.streams.util

Common utilities for Streams components.

ComponentUtils() - Constructor for class org.apache.streams.util.ComponentUtils

ConstantTimeBackOffStrategy - Class in org.apache.streams.util.api.requests.backoff.impl

A AbstractBackOffStrategy that causes the current thread to sleep the same amount of time each time backOff() is called.

ConstantTimeBackOffStrategy(long) - Constructor for class org.apache.streams.util.api.requests.backoff.impl.ConstantTimeBackOffStrategy

A ConstantTimeBackOffStrategy that can effectively be used endlessly.

ConstantTimeBackOffStrategy(long, int) - Constructor for class org.apache.streams.util.api.requests.backoff.impl.ConstantTimeBackOffStrategy

A ConstantTimeBackOffStrategy that has a limited number of uses before it throws a BackOffException

D

DateUtil - Class in org.apache.streams.util

DateUtil() - Constructor for class org.apache.streams.util.DateUtil

deserialize(byte[]) - Static method in class org.apache.streams.util.SerializationUtil

BORROwED FROM APACHE STORM PROJECT

determineDate(String) - Static method in class org.apache.streams.util.DateUtil

determineDateFormat(String) - Static method in class org.apache.streams.util.DateUtil

Determine SimpleDateFormat pattern matching with the given date string.

determineDateTime(String) - Static method in class org.apache.streams.util.DateUtil

determineDateTime(String, DateTimeZone) - Static method in class org.apache.streams.util.DateUtil

E

equals(Object) - Method in class org.apache.streams.util.oauth.tokens.AbstractOauthToken

ExponentialBackOffStrategy - Class in org.apache.streams.util.api.requests.backoff.impl

Exponential backk strategy.

ExponentialBackOffStrategy(int) - Constructor for class org.apache.streams.util.api.requests.backoff.impl.ExponentialBackOffStrategy

Unlimited use ExponentialBackOffStrategy

ExponentialBackOffStrategy(int, int) - Constructor for class org.apache.streams.util.api.requests.backoff.impl.ExponentialBackOffStrategy

Limited use ExponentialBackOffStrategy

G

generateGuid(String...) - Static method in class org.apache.streams.util.GuidUtils

getAliasesForDateRange(String, String, String) - Static method in class org.apache.streams.util.DateUtil

getAliasesForDateRange(DateTime, DateTime, String) - Static method in class org.apache.streams.util.DateUtil

getAliasForDate(String, String) - Static method in class org.apache.streams.util.DateUtil

getAliasForDate(DateTime, String) - Static method in class org.apache.streams.util.DateUtil

getLongestBackOff() - Method in exception org.apache.streams.util.api.requests.backoff.BackOffException

Gets the longest sleep period that the strategy attempted.

getMatchedContent(String, String) - Static method in class org.apache.streams.util.RegexUtils

getMatches(String, String, int) - Static method in class org.apache.streams.util.RegexUtils

getNextAvailableToken() - Method in class org.apache.streams.util.oauth.tokens.tokenmanager.impl.BasicTokenManger

getNextAvailableToken() - Method in interface org.apache.streams.util.oauth.tokens.tokenmanager.SimpleTokenManager

Get an available token.

getNumberOfBackOffsAttempted() - Method in exception org.apache.streams.util.api.requests.backoff.BackOffException

Gets the number of back off attempts that happened before the exception was thrown.

getTwoMatchedGroups(String, String) - Static method in class org.apache.streams.util.RegexUtils

getTwoMatchedGroupsList(List<String>, String) - Static method in class org.apache.streams.util.RegexUtils

GuidUtils - Class in org.apache.streams.util

Created by sblackmon on 12/13/13.

GuidUtils() - Constructor for class org.apache.streams.util.GuidUtils

I

internalEquals(Object) - Method in class org.apache.streams.util.oauth.tokens.AbstractOauthToken

Must create equals method for all OauthTokens.

L

LinearTimeBackOffStrategy - Class in org.apache.streams.util.api.requests.backoff.impl

A AbstractBackOffStrategy that causes back offs in linear increments.

LinearTimeBackOffStrategy(int) - Constructor for class org.apache.streams.util.api.requests.backoff.impl.LinearTimeBackOffStrategy

LinearTimeBackOffStrategy(int, int) - Constructor for class org.apache.streams.util.api.requests.backoff.impl.LinearTimeBackOffStrategy

M

matches(String, String) - Static method in class org.apache.streams.util.RegexUtils

N

numAvailableTokens() - Method in class org.apache.streams.util.oauth.tokens.tokenmanager.impl.BasicTokenManger

numAvailableTokens() - Method in interface org.apache.streams.util.oauth.tokens.tokenmanager.SimpleTokenManager

Get the number of available tokens

O

offerUntilSuccess(T, Queue<T>) - Static method in class org.apache.streams.util.ComponentUtils

Certain types of queues will fail to Queue.offer(Object) an item due to many factors depending on the type of queue.

org.apache.streams.util - package org.apache.streams.util

org.apache.streams.util.api.requests.backoff - package org.apache.streams.util.api.requests.backoff

org.apache.streams.util.api.requests.backoff.impl - package org.apache.streams.util.api.requests.backoff.impl

org.apache.streams.util.oauth.tokens - package org.apache.streams.util.oauth.tokens

org.apache.streams.util.oauth.tokens.tokenmanager - package org.apache.streams.util.oauth.tokens.tokenmanager

org.apache.streams.util.oauth.tokens.tokenmanager.impl - package org.apache.streams.util.oauth.tokens.tokenmanager.impl

P

pollUntilStringNotEmpty(Queue) - Static method in class org.apache.streams.util.ComponentUtils

pollWhileNotEmpty(Queue<T>) - Static method in class org.apache.streams.util.ComponentUtils

Certain types of queues will return null when calling Queue.poll() due to many factors depending on the type of queue.

R

RegexUtils - Class in org.apache.streams.util

RegexUtils() - Constructor for class org.apache.streams.util.RegexUtils

registerLocalMBean(String, V) - Static method in class org.apache.streams.util.ComponentUtils

Attempts to register an object with local MBeanServer.

removeAllMBeansOfDomain(String) - Static method in class org.apache.streams.util.ComponentUtils

Removes all mbeans registered undered a specific domain.

reset() - Method in class org.apache.streams.util.api.requests.backoff.AbstractBackOffStrategy

reset() - Method in interface org.apache.streams.util.api.requests.backoff.BackOffStrategy

Rests the back off strategy to its original state.

S

SerializationUtil - Class in org.apache.streams.util

Created by rebanks on 2/18/14.

SerializationUtil() - Constructor for class org.apache.streams.util.SerializationUtil

serialize(Object) - Static method in class org.apache.streams.util.SerializationUtil

BORROwED FROM APACHE STORM PROJECT

shutdownExecutor(ExecutorService, int, int) - Static method in class org.apache.streams.util.ComponentUtils

Attempts to safely ExecutorService.shutdown() and ExecutorService.awaitTermination(long, java.util.concurrent.TimeUnit) of an ExecutorService.

SimpleTokenManager<T> - Interface in org.apache.streams.util.oauth.tokens.tokenmanager

Manges access to oauth tokens.

A B C D E G I L M N O P R S