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

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.

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.BasicTokenManager

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.BasicTokenManager

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

BackOffException constructor.

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

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

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

Manages a pool of tokens the most basic possible way.

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

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

BasicTokenManager constructor.

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

childQualifiedName(String, String) - Static method in class org.apache.streams.util.schema.SchemaUtil

clearCache() - Method in interface org.apache.streams.util.schema.SchemaStore

clearCache() - Method in class org.apache.streams.util.schema.SchemaStoreImpl

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

clone Object by serialization.

compare(Schema, Schema) - Method in interface org.apache.streams.util.schema.SchemaStore

compare(Schema, Schema) - Method in class org.apache.streams.util.schema.SchemaStoreImpl

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

contentResolver - Variable in class org.apache.streams.util.schema.SchemaStoreImpl

create(URI) - Method in interface org.apache.streams.util.schema.SchemaStore

create(Schema, String) - Method in interface org.apache.streams.util.schema.SchemaStore

create(URI) - Method in class org.apache.streams.util.schema.SchemaStoreImpl

create(Schema, String) - Method in class org.apache.streams.util.schema.SchemaStoreImpl

D

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

deserialize byte array as Object.

determineFieldType(ObjectNode) - Static method in class org.apache.streams.util.schema.FieldUtil

determine FieldType from ObjectNode.

dropExtension(String) - Static method in class org.apache.streams.util.schema.FileUtil

dropExtension.

dropSourcePathPrefix(String, String) - Static method in class org.apache.streams.util.schema.FileUtil

drop source path prefix between inputFile and sourceDirectory.

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 backoff 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.

F

FieldType - Enum in org.apache.streams.util.schema

FieldType defines xsd types that streams schema processing libraries should be able to translate.

FieldUtil - Class in org.apache.streams.util.schema

FieldUtil contains methods to assist in understanding fields defined within schemas.

FieldUtil() - Constructor for class org.apache.streams.util.schema.FieldUtil

FileUtil - Class in org.apache.streams.util.schema

FileUtil contains methods to assist in working with local schema files during source or resource generation.

FileUtil() - Constructor for class org.apache.streams.util.schema.FileUtil

flattenToMap(ObjectNode) - Static method in class org.apache.streams.util.PropertyUtil

flattenToMap(ObjectNode, char) - Static method in class org.apache.streams.util.PropertyUtil

flattenToObjectNode(ObjectNode) - Static method in class org.apache.streams.util.PropertyUtil

flattenToObjectNode(ObjectNode, char) - Static method in class org.apache.streams.util.PropertyUtil

fragmentResolver - Variable in class org.apache.streams.util.schema.SchemaStoreImpl

G

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

generateGuid from list of parts.

GenerationConfig - Interface in org.apache.streams.util.schema

GenerationConfig represents the common fields and field accessors for streams modules that transform schemas into generated-sources or generated-resources.

getById(URI) - Method in interface org.apache.streams.util.schema.SchemaStore

getById(URI) - Method in class org.apache.streams.util.schema.SchemaStoreImpl

getByUri(URI) - Method in interface org.apache.streams.util.schema.SchemaStore

getByUri(URI) - Method in class org.apache.streams.util.schema.SchemaStoreImpl

getContent() - Method in class org.apache.streams.util.schema.Schema

getFileFilter() - Method in interface org.apache.streams.util.schema.GenerationConfig

Gets the file filter used to isolate the schema mapping files in the source directories.

getFileUriCount() - Method in interface org.apache.streams.util.schema.SchemaStore

getFileUriCount() - Method in class org.apache.streams.util.schema.SchemaStoreImpl

getHttpUriCount() - Method in interface org.apache.streams.util.schema.SchemaStore

getHttpUriCount() - Method in class org.apache.streams.util.schema.SchemaStoreImpl

getId() - Method in class org.apache.streams.util.schema.Schema

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

Gets the longest sleep period that the strategy attempted.

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

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.

getOutputEncoding() - Method in interface org.apache.streams.util.schema.GenerationConfig

Gets the 'outputEncoding' configuration option.

getParent() - Method in class org.apache.streams.util.schema.Schema

getParentContent() - Method in class org.apache.streams.util.schema.Schema

getParentContent.

getParentUri() - Method in class org.apache.streams.util.schema.Schema

getParentUri.

getSchemaIterator() - Method in interface org.apache.streams.util.schema.SchemaStore

getSchemaIterator() - Method in class org.apache.streams.util.schema.SchemaStoreImpl

getSize() - Method in interface org.apache.streams.util.schema.SchemaStore

getSize() - Method in class org.apache.streams.util.schema.SchemaStoreImpl

getSource() - Method in interface org.apache.streams.util.schema.GenerationConfig

Gets the 'source' configuration option.

getTargetDirectory() - Method in interface org.apache.streams.util.schema.GenerationConfig

Gets the 'targetDirectory' configuration option.

getUri() - Method in class org.apache.streams.util.schema.Schema

GuidUtils - Class in org.apache.streams.util

GuidUtils contains methods for generating guids from identifiers.

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

I

ILLEGAL_CHARACTER_REGEX - Static variable in class org.apache.streams.util.schema.SchemaUtil

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

Must create equals method for all OauthTokens.

isGenerated() - Method in class org.apache.streams.util.schema.Schema

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

mergeProperties(ObjectNode, ObjectNode) - Static method in class org.apache.streams.util.schema.SchemaUtil

merge parent and child properties maps.

N

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

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

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

P

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.

PropertyUtil - Class in org.apache.streams.util

Class transforms nested properties of activities, actors, objects, etc...

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

R

readSchema(URL) - Static method in class org.apache.streams.util.schema.SchemaUtil

read Schema from URL.

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.

removeFile(URI) - Static method in class org.apache.streams.util.schema.UriUtil

removeFragment(URI) - Static method in class org.apache.streams.util.schema.UriUtil

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.

resolveItems(Schema, ObjectNode, String) - Method in interface org.apache.streams.util.schema.SchemaStore

resolveItems(Schema, ObjectNode, String) - Method in class org.apache.streams.util.schema.SchemaStoreImpl

resolve full definition of 'items'.

resolveProperties(Schema, ObjectNode, String) - Method in interface org.apache.streams.util.schema.SchemaStore

resolveProperties(Schema, ObjectNode, String) - Method in class org.apache.streams.util.schema.SchemaStoreImpl

resolveRecursive(GenerationConfig, List<File>) - Static method in class org.apache.streams.util.schema.FileUtil

resolveRecursive.

S

safeResolve(URI, String) - Static method in class org.apache.streams.util.schema.UriUtil

resolve a remote schema safely.

Schema - Class in org.apache.streams.util.schema

A JSON Schema document.

Schema(URI, JsonNode, Schema, boolean) - Constructor for class org.apache.streams.util.schema.Schema

Schema constructor.

schemas - Variable in class org.apache.streams.util.schema.SchemaStoreImpl

SchemaStore - Interface in org.apache.streams.util.schema

A SchemaStore resolves and indexes json schemas and makes their properties available.

SchemaStoreImpl - Class in org.apache.streams.util.schema

Default Implementation of SchemaStore.

SchemaStoreImpl() - Constructor for class org.apache.streams.util.schema.SchemaStoreImpl

SchemaUtil - Class in org.apache.streams.util.schema

SchemaUtil contains methods to assist in resolving schemas and schema fragments.

SchemaUtil() - Constructor for class org.apache.streams.util.schema.SchemaUtil

selfReferenceWithoutParentFile(Schema, String) - Method in class org.apache.streams.util.schema.SchemaStoreImpl

SerializationUtil - Class in org.apache.streams.util

SerializationUtil contains methods for serializing, deserializing, and cloning documents and tasks.

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

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

serialize Object as byte array.

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

Manages access to oauth tokens.

swapExtension(String, String, String) - Static method in class org.apache.streams.util.schema.FileUtil

swapExtension.

U

unflattenMap(Map<String, Object>, char) - Static method in class org.apache.streams.util.PropertyUtil

unflattenObjectNode(ObjectNode, char) - Static method in class org.apache.streams.util.PropertyUtil

UriUtil - Class in org.apache.streams.util.schema

UriUtil contains methods to assist in resolving URIs and URI fragments.

UriUtil() - Constructor for class org.apache.streams.util.schema.UriUtil

V

valueOf(String) - Static method in enum org.apache.streams.util.schema.FieldType

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

values() - Static method in enum org.apache.streams.util.schema.FieldType

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

W

writeFile(String, String) - Static method in class org.apache.streams.util.schema.FileUtil

writeFile.

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