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.