Package net.shibboleth.metadata.pipeline
package net.shibboleth.metadata.pipeline
A set of classes for constructing generic data processing pipelines.
-
ClassDescriptionAn abstract
Stagethat selectsItems for further processing if they have a specific type ofItemMetadataattached to them.A base class forStageimplementations.APredicatewhich returnstrueif and only if the number of elements in the supplied collection is at least the configured minimum value.A stage that is composed of other stages.An output strategy for use with theMultiOutputSerializationStagewhich generates individual files within a directory.A pipeline stage that adds a collection ofItemMetadataobjects to eachItem's item metadata.AStagethat terminates pipeline processing if anItemhas a specific type ofItemMetadataattached to it.A strategy that defines how to order aItemcollection.Transforms a string into another string that is the MD5 hash of the UTF-8 encoding of the original string, prepended with "{md5}".Transforms a string into another string that is the hex-encoded representation of the SHA1 hash of the UTF-8 encoding of the original string, prepended with "{sha1}".A stage which writes the given item collection out to multiple destinations.Interface implemented by destination objects created by anMultiOutputSerializationStage.OutputStrategy.Interface to be implemented by strategy object determining where an item should be written.Pipeline<T>A stage which, given an item collection and a list ofPipelineAndStrategyobjects each representing aPipelines and associated selection strategyPredicate, sends the collection of item copies selected by the predicate to the associated pipeline.Base exception for errors that occur within the pipeline execution.A pipeline stage that computes that transforms the collection ofItemvia a script.A stage which writes the given item collection out to a file using a providedItemCollectionSerializer.A very simple implementation ofPipeline.A stage which splits a given collection according to a provided selection strategy and passes selected items to one pipeline and non-selected items to another.Stage<T>Exception indicating that aStageof the pipeline encountered an error.A stage which adds a static collection of Items to aItemcollection.An exception to be thrown to cause command-line aggregator execution to terminate.