public class PublisherUtils extends Object
DataPublisher.| Modifier and Type | Class and Description |
|---|---|
static class |
PublisherUtils.SplitExtractsResult |
static class |
PublisherUtils.WorkUnitStateSuccess
Implementation of
Predicate that checks if a given WorkUnitState has a WorkUnitState.WorkingState equal
to WorkUnitState.WorkingState.SUCCESSFUL. |
| Constructor and Description |
|---|
PublisherUtils() |
| Modifier and Type | Method and Description |
|---|---|
static Multimap<Extract,WorkUnitState> |
createExtractToWorkUnitStateMap(Collection<? extends WorkUnitState> workUnitStates)
|
static Multimap<Extract,WorkUnitState> |
getExtractsForPredicate(Multimap<Extract,WorkUnitState> extractToWorkUnitStateMap,
Predicate<WorkUnitState> predicate)
Given a
Multimap of Extracts to WorkUnitStates, filter out any Extracts where all
of the corresponding WorkUnitStates do not meet the given Predicate. |
static PublisherUtils.SplitExtractsResult |
splitExtractsByPredicate(Multimap<Extract,WorkUnitState> extractToWorkUnitStateMap,
Predicate<WorkUnitState> predicate)
Given a
Multimap of Extracts to WorkUnitStates, filter out any Extracts where all
of the corresponding WorkUnitStates do not meet the given Predicate. |
public static Multimap<Extract,WorkUnitState> createExtractToWorkUnitStateMap(Collection<? extends WorkUnitState> workUnitStates)
Multimappublic static Multimap<Extract,WorkUnitState> getExtractsForPredicate(Multimap<Extract,WorkUnitState> extractToWorkUnitStateMap, Predicate<WorkUnitState> predicate)
Multimap of Extracts to WorkUnitStates, filter out any Extracts where all
of the corresponding WorkUnitStates do not meet the given Predicate.public static PublisherUtils.SplitExtractsResult splitExtractsByPredicate(Multimap<Extract,WorkUnitState> extractToWorkUnitStateMap, Predicate<WorkUnitState> predicate)
Multimap of Extracts to WorkUnitStates, filter out any Extracts where all
of the corresponding WorkUnitStates do not meet the given Predicate.