public class CleanAdditionalPropertiesProcessor extends Object implements StreamsProcessor
| Modifier and Type | Field and Description |
|---|---|
static String |
STREAMS_ID |
| Constructor and Description |
|---|
CleanAdditionalPropertiesProcessor() |
| Modifier and Type | Method and Description |
|---|---|
static void |
cleanAdditionalProperties(com.fasterxml.jackson.databind.node.ObjectNode node)
Recursively removes all additionalProperties maps.
|
void |
cleanUp() |
String |
getId() |
void |
prepare(Object configurationObject) |
List<StreamsDatum> |
process(StreamsDatum datum) |
public static final String STREAMS_ID
public String getId()
getId in interface StreamsOperationpublic List<StreamsDatum> process(StreamsDatum datum)
process in interface StreamsProcessorpublic void prepare(Object configurationObject)
prepare in interface StreamsOperationpublic void cleanUp()
cleanUp in interface StreamsOperationpublic static void cleanAdditionalProperties(com.fasterxml.jackson.databind.node.ObjectNode node)
node - ObjectNodeCopyright © 2018 The Apache Software Foundation. All rights reserved.