public class TypeConverterProcessor extends Object implements StreamsProcessor
Modifier and Type | Field and Description |
---|---|
static String |
STREAMS_ID |
Constructor and Description |
---|
TypeConverterProcessor(Class inClass,
Class outClass)
TypeConverterProcessor constructor.
|
TypeConverterProcessor(Class inClass,
Class outClass,
List<String> formats)
TypeConverterProcessor constructor.
|
TypeConverterProcessor(Class inClass,
Class outClass,
com.fasterxml.jackson.databind.ObjectMapper mapper)
TypeConverterProcessor constructor.
|
Modifier and Type | Method and Description |
---|---|
void |
cleanUp() |
String |
getId() |
void |
prepare(Object configurationObject) |
List<StreamsDatum> |
process(StreamsDatum entry) |
public static final String STREAMS_ID
public TypeConverterProcessor(Class inClass, Class outClass, com.fasterxml.jackson.databind.ObjectMapper mapper)
inClass
- inClassoutClass
- outClassmapper
- mapperpublic TypeConverterProcessor(Class inClass, Class outClass, List<String> formats)
inClass
- inClassoutClass
- outClassformats
- formatspublic 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.