Uses of Interface
adams.flow.control.StorageUpdater

Packages that use StorageUpdater

Package	Description
adams.core.command.stderr
adams.core.command.stdout
adams.flow.sink
adams.flow.source
adams.flow.standalone
adams.flow.transformer

Uses of StorageUpdater in adams.core.command.stderr

Classes in adams.core.command.stderr that implement StorageUpdater

Modifier and Type	Class	Description
class	Enqueue	Adds the output from stderr to the specified queue.

Uses of StorageUpdater in adams.core.command.stdout

Classes in adams.core.command.stdout that implement StorageUpdater

Modifier and Type	Class	Description
class	Enqueue	Adds the output from stdout to the specified queue.

Uses of StorageUpdater in adams.flow.sink

Classes in adams.flow.sink that implement StorageUpdater

Modifier and Type	Class	Description
class	EnQueue	Enqueues the incoming data in the specified queue in internal storage.
class	Publish	Publishes the incoming data using the specified publish/subscribe handler in storage.

Uses of StorageUpdater in adams.flow.source

Classes in adams.flow.source that implement StorageUpdater

Modifier and Type	Class	Description
class	DeQueue	Polls the specified queue in internal storage for an item, blocks till an item is available. NB: The user needs to stop the flow as the DeQueue source will never stop, as it assumes that there will be more data coming through.

Uses of StorageUpdater in adams.flow.standalone

Classes in adams.flow.standalone that implement StorageUpdater

Modifier and Type	Class	Description
class	CounterInit	Creates an empty counter in internal storage under the specified name.
class	DeleteStorageValue	Removes the specified value (or the ones that match the regular expression) from temporary storage. By supplying a cache name, the value can be removed from a LRU cache instead of the regular storage.
class	DeserializeToStorage	Deserializes a model from a file with the specified object reader and stores it directly in storage. It is also possible to define multiple storage name / file name pairs, to make the deserialization of large amounts of files more efficient.
class	HashSetInit	Creates an empty hashset in internal storage under the specified name. Initial string values can be supplied as well, which can be transformed using the specified conversion. See also: adams.flow.transformer.HashSetInit adams.flow.transformer.HashSetAdd adams.flow.source.HashSet adams.flow.condition.bool.HashSet
class	InitPublishSubscribe	Initializes a publish/subscribe data structure in internal storage.
class	LookUpInit	Initializes an empty look up table in storage. See also: adams.flow.transformer.LookUpAdd
class	QueueInit	Creates an empty queue in internal storage under the specified name.

Uses of StorageUpdater in adams.flow.transformer

Classes in adams.flow.transformer that implement StorageUpdater

Modifier and Type	Class	Description
class	AbstractDataContainerAdd<T extends DataContainer>	Ancestor for transformers that superimpose the incoming data container on one available from storage (or if not available, put the current one in storage) and forward the combined data container.
class	AbstractDataContainerAppend<T extends DataContainer>	Ancestor for transformers that append the incoming data container to one available from storage (or if not available, put the current one in storage) and forward the combined data container.
class	CollectionAppend	Appends the elements of the incoming collection to the one in storage. If there is none in storage yet, a copy of the incoming collection will simply get stored in storage. The combined collection is then forwarded.
class	CounterInit	Creates a counter from a column in a spreadsheet or an array.
class	DeleteStorageValue	Removes the specified value (or the ones that match the regular expression) from temporary storage whenever a token passes through. By supplying a cache name, the value can be removed from a LRU cache instead of the regular storage.
class	HashSetInit	Creates a hashset from a column in a spreadsheet or an array.
class	IncStorageValue	Increments the value of a storage value by either an integer or double increment. If the storage value has not been set yet, it will get set to 0. If the storage value contains a non-numerical value, no increment will be performed. It is also possible to directly output the updated storage value (while discarding the input token).
class	LookUpInit	Creates a lookup table from a spreadsheet, using one column as key and another one as value.
class	SetStorageFlag	Stores the flag value in storage using the specified name whenever a token passes through.
class	SetStorageValue	Stores the payload of the token passing through under the specified name in temporary storage.
class	SpreadSheetAppend	Appends the incoming spreadsheet to one in storage. If there is none in storage yet, the incoming spreadsheet will simply get stored in storage. The spreadsheets need not have the same structure, but it is assumed that column names are unique within a spreadsheet. The combined spreadsheet is then forwarded.
class	StorageCollectionInsert	Inserts the object passing through to the collection in storage at the specified position. After inserting the object successfully, just forwards the object. If the collection does not implement the java.util.List interface and the insertion is not at the end, the insertion will fail. See also: adams.flow.transformer.CollectionInsert Input/output: - accepts: adams.flow.core.Unknown - generates: adams.flow.core.Unknown
class	StorageJFreeChartAddSeries	Generates a series from the incoming spreadsheet and adds it to the specified JFreeChart dataset in storage. After inserting the object successfully, just forwards the object.
class	TimeseriesAdd	Appends the incoming timeseries to the one available from storage. If none yet available from storage, then the current one simply put into storage. If the timeseries already contains elements with the same timestamp, then these will get replaced by the current ones.
class	TimeseriesAppend	Appends the incoming timeseries to the one available from storage. If none yet available from storage, then the current one simply put into storage. If the timeseries already contains elements with the same timestamp, then these will get replaced by the current ones.