public class FacebookTypeConverter extends Object implements StreamsProcessor
Modifier and Type | Field and Description |
---|---|
static String |
STREAMS_ID |
static String |
TERMINATE |
Constructor and Description |
---|
FacebookTypeConverter(Class inClass,
Class outClass) |
Modifier and Type | Method and Description |
---|---|
void |
cleanUp() |
Object |
convert(com.fasterxml.jackson.databind.node.ObjectNode event,
Class inClass,
Class outClass)
convert.
|
String |
getId() |
Queue<StreamsDatum> |
getProcessorOutputQueue() |
boolean |
isValidJSON(String json) |
void |
prepare(Object configurationObject) |
List<StreamsDatum> |
process(StreamsDatum entry) |
void |
setProcessorInputQueue(Queue<StreamsDatum> inputQueue) |
boolean |
validate(Object document,
Class klass) |
public static final String STREAMS_ID
public static final String TERMINATE
public Queue<StreamsDatum> getProcessorOutputQueue()
public void setProcessorInputQueue(Queue<StreamsDatum> inputQueue)
public Object convert(com.fasterxml.jackson.databind.node.ObjectNode event, Class inClass, Class outClass) throws ActivitySerializerException, com.fasterxml.jackson.core.JsonProcessingException
event
- eventinClass
- inClassoutClass
- outClassActivitySerializerException
- ActivitySerializerExceptioncom.fasterxml.jackson.core.JsonProcessingException
- JsonProcessingExceptionpublic boolean isValidJSON(String json)
public String getId()
getId
in interface StreamsOperation
public List<StreamsDatum> process(StreamsDatum entry)
process
in interface StreamsProcessor
public void prepare(Object configurationObject)
prepare
in interface StreamsOperation
public void cleanUp()
cleanUp
in interface StreamsOperation
Copyright © 2018 The Apache Software Foundation. All rights reserved.