Package | Description |
---|---|
org.kitesdk.morphline.api |
This package contains the heart of the morphline API.
|
org.kitesdk.morphline.base | |
org.kitesdk.morphline.stdio | |
org.kitesdk.morphline.stdlib |
Modifier and Type | Method and Description |
---|---|
Record |
Record.copy()
Returns a shallow copy of this record.
|
Modifier and Type | Method and Description |
---|---|
void |
ExceptionHandler.handleException(Throwable t,
Record record)
Handle the given exception resulting from the given input record (the record can be null)
|
void |
Command.notify(Record notification)
Processes the given notification on the control plane of the subtree rooted at this command.
|
boolean |
Command.process(Record record)
Processes the given record on the data plane of this command.
|
Modifier and Type | Method and Description |
---|---|
static boolean |
Notifications.containsLifecycleEvent(Record notification,
Notifications.LifecycleEvent event)
Determine whether or not the given notification contains the given lifecycle event.
|
protected void |
AbstractCommand.doNotify(Record notification)
Processes the given notification on the control plane of the subtree rooted at this command.
|
protected boolean |
AbstractCommand.doProcess(Record record)
Processes the given record on the data plane of this command.
|
List |
FieldExpression.evaluate(Record record)
Returns the values of a
Record referred to by the given field expression |
static List |
Notifications.getLifecycleEvents(Record notification)
Get all lifecycle events from the given record.
|
void |
FaultTolerance.handleException(Throwable t,
Record record) |
void |
AbstractCommand.notify(Record notification) |
boolean |
AbstractCommand.process(Record record) |
Modifier and Type | Method and Description |
---|---|
protected Charset |
AbstractParser.detectCharset(Record record,
Charset charset) |
protected boolean |
AbstractParser.doProcess(Record record) |
protected abstract boolean |
AbstractParser.doProcess(Record record,
InputStream stream) |
static void |
AbstractParser.removeAttachments(Record outputRecord) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
AbstractFieldTransformCommand.doProcess(Record record) |
Copyright © 2013–2015. All rights reserved.