public class DatumUtils extends Object
Constructor and Description |
---|
DatumUtils() |
Modifier and Type | Method and Description |
---|---|
static void |
addErrorToMetadata(StreamsDatum datum,
Throwable e,
Class<? extends StreamsOperation> operationClass)
Adds an error occurred during a StreamsOperation step to the StreamsDatum's metadata.
|
static StreamsDatum |
cloneDatum(StreamsDatum datum) |
public static void addErrorToMetadata(StreamsDatum datum, Throwable e, Class<? extends StreamsOperation> operationClass)
datum
- the datum on which the operation step errorede
- the error encounteredoperationClass
- the class of the operationpublic static StreamsDatum cloneDatum(StreamsDatum datum)
Copyright © 2012–2016 The Apache Software Foundation. All rights reserved.