A B C E G H I L M O P Q R S U V

A

AbstractRequestBuilder - Class in org.apache.streams.sysomos.provider

Defines a common pattern for requesting data from the Sysomos API.

AbstractRequestBuilder() - Constructor for class org.apache.streams.sysomos.provider.AbstractRequestBuilder

addQuery(String) - Method in class org.apache.streams.sysomos.data.SysomosTagDefinition

API_BATCH_SIZE - Static variable in class org.apache.streams.sysomos.provider.SysomosProvider

B

BASE_URL_STRING - Static variable in class org.apache.streams.sysomos.provider.SysomosClient

C

cleanUp() - Method in class org.apache.streams.sysomos.processor.SysomosTypeConverter

cleanUp() - Method in class org.apache.streams.sysomos.provider.SysomosProvider

CODE_PATTERN - Static variable in class org.apache.streams.sysomos.util.SysomosUtils

ContentRequestBuilder - Class in org.apache.streams.sysomos.provider

Builds requests for the Sysomos Heartbeat Content API.

ContentRequestBuilder(String, String) - Constructor for class org.apache.streams.sysomos.provider.ContentRequestBuilder

Constructs a new ContentRequestBuilder for the specified API key and Sysomos URL

convert(BeatApi.BeatResponse.Beat) - Method in class org.apache.streams.sysomos.conversion.SysomosBeatActivityConverter

createRequestBuilder() - Method in class org.apache.streams.sysomos.provider.SysomosClient

createStream(String) - Method in class org.apache.streams.sysomos.provider.SysomosProvider

E

ENDING_TIME_KEY - Static variable in class org.apache.streams.sysomos.provider.SysomosProvider

enqueueItem(StreamsDatum) - Method in class org.apache.streams.sysomos.provider.SysomosProvider

equals(Object) - Method in class org.apache.streams.sysomos.data.SysomosTagDefinition

execute() - Method in class org.apache.streams.sysomos.provider.AbstractRequestBuilder

Executes the request to the Sysomos Heartbeat API and returns a valid response

execute() - Method in interface org.apache.streams.sysomos.provider.RequestBuilder

Executes the request to the Sysomos Heartbeat API and returns a valid response

executeAPIRequest() - Method in class org.apache.streams.sysomos.provider.SysomosHeartbeatStream

executeRun() - Method in class org.apache.streams.sysomos.provider.SysomosHeartbeatStream

extractConfigFromMap(Map) - Method in class org.apache.streams.sysomos.provider.SysomosProvider

G

getClient() - Method in class org.apache.streams.sysomos.provider.SysomosProvider

getConfig() - Method in class org.apache.streams.sysomos.provider.SysomosProvider

getCount() - Method in class org.apache.streams.sysomos.provider.SysomosProvider

getCurrentId() - Method in class org.apache.streams.sysomos.provider.SysomosHeartbeatStream.QueryResult

getDisplayName() - Method in class org.apache.streams.sysomos.data.SysomosTagDefinition

getErrorCode() - Method in exception org.apache.streams.sysomos.SysomosException

getHeartbeatInfo(String) - Method in class org.apache.streams.sysomos.provider.SysomosClient

getId() - Method in class org.apache.streams.sysomos.processor.SysomosTypeConverter

getId() - Method in class org.apache.streams.sysomos.provider.SysomosProvider

getMaxApiBatch() - Method in class org.apache.streams.sysomos.provider.SysomosProvider

getMinLatency() - Method in class org.apache.streams.sysomos.provider.SysomosProvider

getMode() - Method in class org.apache.streams.sysomos.provider.SysomosProvider

getQueries() - Method in class org.apache.streams.sysomos.data.SysomosTagDefinition

getRequestUrl() - Method in class org.apache.streams.sysomos.provider.ContentRequestBuilder

Gets the Request URL based on the local fields

getRequestUrl() - Method in interface org.apache.streams.sysomos.provider.RequestBuilder

Returns the full url need to execute a request.

getResponseSize() - Method in class org.apache.streams.sysomos.provider.SysomosHeartbeatStream.QueryResult

getTagDefinitions() - Method in class org.apache.streams.sysomos.data.HeartbeatInfo

getTagName() - Method in class org.apache.streams.sysomos.data.SysomosTagDefinition

getTagWithDisplayName(String) - Method in class org.apache.streams.sysomos.data.HeartbeatInfo

getTagWithTagName(String) - Method in class org.apache.streams.sysomos.data.HeartbeatInfo

H

hasDisplayName(String) - Method in class org.apache.streams.sysomos.data.SysomosTagDefinition

hasQuery(String) - Method in class org.apache.streams.sysomos.data.SysomosTagDefinition

hasTagName(String) - Method in class org.apache.streams.sysomos.data.HeartbeatInfo

hasTagName(String) - Method in class org.apache.streams.sysomos.data.SysomosTagDefinition

hasTagWithDisplayName(String) - Method in class org.apache.streams.sysomos.data.HeartbeatInfo

HeartbeatInfo - Class in org.apache.streams.sysomos.data

Represents Heatbeat metadata from the Sysomos API

HeartbeatInfo(String) - Constructor for class org.apache.streams.sysomos.data.HeartbeatInfo

I

isMatchedLastId() - Method in class org.apache.streams.sysomos.provider.SysomosHeartbeatStream.QueryResult

isRunning() - Method in class org.apache.streams.sysomos.provider.SysomosProvider

L

LATENCY - Static variable in class org.apache.streams.sysomos.provider.SysomosProvider

M

main(String[]) - Static method in class org.apache.streams.sysomos.provider.SysomosProvider

mapTags(BeatApi.BeatResponse.Beat) - Method in class org.apache.streams.sysomos.conversion.SysomosBeatActivityConverter

MAX_ALLOWED_PER_REQUEST - Static variable in class org.apache.streams.sysomos.provider.ContentRequestBuilder

The max number of items you are allowed to get per request.

MODE_KEY - Static variable in class org.apache.streams.sysomos.provider.SysomosProvider

O

org.apache.streams.sysomos - package org.apache.streams.sysomos

org.apache.streams.sysomos.conversion - package org.apache.streams.sysomos.conversion

org.apache.streams.sysomos.data - package org.apache.streams.sysomos.data

org.apache.streams.sysomos.processor - package org.apache.streams.sysomos.processor

org.apache.streams.sysomos.provider - package org.apache.streams.sysomos.provider

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

P

pauseForSpace() - Method in class org.apache.streams.sysomos.provider.SysomosProvider

Wait for the queue size to be below threshold before allowing execution to continue on this thread

prepare(Object) - Method in class org.apache.streams.sysomos.processor.SysomosTypeConverter

prepare(Object) - Method in class org.apache.streams.sysomos.provider.SysomosProvider

process(StreamsDatum) - Method in class org.apache.streams.sysomos.processor.SysomosTypeConverter

PROVIDER_BATCH_SIZE - Static variable in class org.apache.streams.sysomos.provider.SysomosProvider

providerQueue - Variable in class org.apache.streams.sysomos.provider.SysomosProvider

Q

queryAPI() - Method in class org.apache.streams.sysomos.provider.SysomosHeartbeatStream

QueryResult(boolean, String, int) - Constructor for class org.apache.streams.sysomos.provider.SysomosHeartbeatStream.QueryResult

queryUrl(URL) - Static method in class org.apache.streams.sysomos.util.SysomosUtils

Queries the sysomos URL and provides the response as a String

R

readCurrent() - Method in class org.apache.streams.sysomos.provider.SysomosProvider

readNew(BigInteger) - Method in class org.apache.streams.sysomos.provider.SysomosProvider

readRange(DateTime, DateTime) - Method in class org.apache.streams.sysomos.provider.SysomosProvider

RequestBuilder - Interface in org.apache.streams.sysomos.provider

Simplifying abstraction that aids in building a request to the Sysomos API in a chained fashion

run() - Method in class org.apache.streams.sysomos.provider.SysomosHeartbeatStream

S

setAddedAfterDate(DateTime) - Method in class org.apache.streams.sysomos.provider.ContentRequestBuilder

setAddedAfterDate(DateTime) - Method in interface org.apache.streams.sysomos.provider.RequestBuilder

Sets the date after which documents should be returned from Sysomos

setAddedBeforeDate(DateTime) - Method in class org.apache.streams.sysomos.provider.ContentRequestBuilder

setAddedBeforeDate(DateTime) - Method in interface org.apache.streams.sysomos.provider.RequestBuilder

Sets the date before which documents should be returned from Sysomos

setChannelSpecificValues(BeatApi.BeatResponse.Beat, Activity, Map<String, BeatApi.BeatResponse.Beat.Tag>) - Method in class org.apache.streams.sysomos.conversion.SysomosBeatActivityConverter

setConfig(SysomosConfiguration) - Method in class org.apache.streams.sysomos.provider.SysomosProvider

setCurrentId(String) - Method in class org.apache.streams.sysomos.provider.SysomosHeartbeatStream.QueryResult

setHeartBeatId(int) - Method in class org.apache.streams.sysomos.provider.ContentRequestBuilder

setHeartBeatId(String) - Method in class org.apache.streams.sysomos.provider.ContentRequestBuilder

setHeartBeatId(int) - Method in interface org.apache.streams.sysomos.provider.RequestBuilder

Sets the Sysomos Heartbeat ID

setHeartBeatId(String) - Method in interface org.apache.streams.sysomos.provider.RequestBuilder

Sets the Sysomos Heartbeat ID as a String

setLanguage(Map<String, BeatApi.BeatResponse.Beat.Tag>, Map<String, Object>) - Method in class org.apache.streams.sysomos.conversion.SysomosBeatActivityConverter

setLocation(BeatApi.BeatResponse.Beat, Map<String, Object>) - Method in class org.apache.streams.sysomos.conversion.SysomosBeatActivityConverter

setMatchedLastId(boolean) - Method in class org.apache.streams.sysomos.provider.SysomosHeartbeatStream.QueryResult

setObject(BeatApi.BeatResponse.Beat, Activity) - Method in class org.apache.streams.sysomos.conversion.SysomosBeatActivityConverter

setOffset(long) - Method in class org.apache.streams.sysomos.provider.ContentRequestBuilder

setOffset(long) - Method in interface org.apache.streams.sysomos.provider.RequestBuilder

Sets the starting offset for the number of documents given the other parameters

setProvider(BeatApi.BeatResponse.Beat, Activity) - Method in class org.apache.streams.sysomos.conversion.SysomosBeatActivityConverter

setResponseSize(int) - Method in class org.apache.streams.sysomos.provider.SysomosHeartbeatStream.QueryResult

setReturnSetSize(long) - Method in class org.apache.streams.sysomos.provider.ContentRequestBuilder

setReturnSetSize(long) - Method in interface org.apache.streams.sysomos.provider.RequestBuilder

Sets the size of the expected response

shutdown() - Method in class org.apache.streams.sysomos.provider.SysomosHeartbeatStream

signalComplete(String) - Method in class org.apache.streams.sysomos.provider.SysomosProvider

sleep() - Method in class org.apache.streams.sysomos.provider.SysomosHeartbeatStream

STARTING_DOCS_KEY - Static variable in class org.apache.streams.sysomos.provider.SysomosProvider

STARTING_TIME_KEY - Static variable in class org.apache.streams.sysomos.provider.SysomosProvider

startStream() - Method in class org.apache.streams.sysomos.provider.SysomosProvider

STREAMS_ID - Static variable in class org.apache.streams.sysomos.processor.SysomosTypeConverter

STREAMS_ID - Static variable in class org.apache.streams.sysomos.provider.SysomosProvider

SYSOMOS_DATE_FORMATTER - Static variable in class org.apache.streams.sysomos.util.SysomosUtils

SysomosBeatActivityConverter - Class in org.apache.streams.sysomos.conversion

Converts an instance of a com.sysomos.xml.BeatApi.BeatResponse.Beat to an Activity

SysomosBeatActivityConverter() - Constructor for class org.apache.streams.sysomos.conversion.SysomosBeatActivityConverter

SysomosClient - Class in org.apache.streams.sysomos.provider

Wrapper for the Sysomos API.

SysomosClient(String) - Constructor for class org.apache.streams.sysomos.provider.SysomosClient

SysomosException - Exception in org.apache.streams.sysomos

Runtime exception wrapper for Sysomos Errors

SysomosException() - Constructor for exception org.apache.streams.sysomos.SysomosException

SysomosException(String) - Constructor for exception org.apache.streams.sysomos.SysomosException

SysomosException(Throwable) - Constructor for exception org.apache.streams.sysomos.SysomosException

SysomosException(String, Throwable) - Constructor for exception org.apache.streams.sysomos.SysomosException

SysomosException(String, int) - Constructor for exception org.apache.streams.sysomos.SysomosException

SysomosException(String, Throwable, int) - Constructor for exception org.apache.streams.sysomos.SysomosException

SysomosHeartbeatStream - Class in org.apache.streams.sysomos.provider

Provides a Runnable query mechanism for grabbing documents from the Sysomos API

SysomosHeartbeatStream(SysomosProvider, String) - Constructor for class org.apache.streams.sysomos.provider.SysomosHeartbeatStream

SysomosHeartbeatStream(SysomosProvider, String, DateTime, DateTime) - Constructor for class org.apache.streams.sysomos.provider.SysomosHeartbeatStream

SysomosHeartbeatStream(SysomosProvider, String, String) - Constructor for class org.apache.streams.sysomos.provider.SysomosHeartbeatStream

SysomosHeartbeatStream(SysomosProvider, String, SysomosHeartbeatStream.OperatingMode) - Constructor for class org.apache.streams.sysomos.provider.SysomosHeartbeatStream

SysomosHeartbeatStream.QueryResult - Class in org.apache.streams.sysomos.provider

SysomosProvider - Class in org.apache.streams.sysomos.provider

Streams Provider for the Sysomos Heartbeat API Configuration: The provider takes either a Map containing the mode (backfill and terminate OR continuous) and a Map of heartbeat IDs to document target ids or a string of the format ${heartbeatId}:${documentId},...,${heartbeatId}:${documentId} This configuration will configure the provider to backfill to the specified document and either terminate or not depending on the mode flag.

SysomosProvider(SysomosConfiguration) - Constructor for class org.apache.streams.sysomos.provider.SysomosProvider

SysomosProvider.Mode - Enum in org.apache.streams.sysomos.provider

SysomosTagDefinition - Class in org.apache.streams.sysomos.data

Represents a Sysomos Heartbeat Tag.

SysomosTagDefinition(String, String) - Constructor for class org.apache.streams.sysomos.data.SysomosTagDefinition

SysomosTypeConverter - Class in org.apache.streams.sysomos.processor

Stream processor that converts Sysomos type to Activity

SysomosTypeConverter() - Constructor for class org.apache.streams.sysomos.processor.SysomosTypeConverter

SysomosUtils - Class in org.apache.streams.sysomos.util

Provides utilities for working with Sysomos

U

updateOffset(SysomosHeartbeatStream.QueryResult) - Method in class org.apache.streams.sysomos.provider.SysomosHeartbeatStream

updateState(SysomosHeartbeatStream.QueryResult, String, int) - Method in class org.apache.streams.sysomos.provider.SysomosHeartbeatStream

V

valueOf(String) - Static method in enum org.apache.streams.sysomos.provider.SysomosProvider.Mode

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

values() - Static method in enum org.apache.streams.sysomos.provider.SysomosProvider.Mode

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

A B C E G H I L M O P Q R S U V