public class LinkResolverProcessor extends Object implements StreamsProcessor
| Constructor and Description | 
|---|
LinkResolverProcessor()  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
cleanUp()  | 
String | 
getId()  | 
void | 
prepare(Object o)  | 
List<StreamsDatum> | 
process(StreamsDatum entry)  | 
protected Set<String> | 
unwind(List<String> inputLinks)  | 
public String getId()
getId in interface StreamsOperationpublic List<StreamsDatum> process(StreamsDatum entry)
process in interface StreamsProcessorpublic void prepare(Object o)
prepare in interface StreamsOperationpublic void cleanUp()
cleanUp in interface StreamsOperationCopyright © 2018 The Apache Software Foundation. All rights reserved.