public abstract class AbstractRegexExtensionExtractor<T> extends Object implements StreamsProcessor
Activity
extensions object.Modifier | Constructor and Description |
---|---|
protected |
AbstractRegexExtensionExtractor(String patternConfigKey,
String extensionKey,
String defaultPattern) |
Modifier and Type | Method and Description |
---|---|
void |
cleanUp() |
protected Collection<T> |
ensureTargetObject(Activity activity) |
String |
getPattern() |
void |
prepare(Object configurationObject) |
protected abstract T |
prepareObject(String extracted)
Configures the value to be persisted to the extensions object.
|
List<StreamsDatum> |
process(StreamsDatum entry) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getId
public String getPattern()
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
protected abstract T prepareObject(String extracted)
extracted
- the value extracted by the regexprotected Collection<T> ensureTargetObject(Activity activity)
Copyright © 2018 The Apache Software Foundation. All rights reserved.