org.apache.streams.core.util

Class DatumUtils

java.lang.Object

org.apache.streams.core.util.DatumUtils

public class DatumUtils
extends Object

Provides common utilities for managing and manipulating StreamsDatums

Constructor Summary

Constructors

Constructor and Description
DatumUtils()

Method Summary

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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DatumUtils

public DatumUtils()

Method Detail

addErrorToMetadata

public static void addErrorToMetadata(StreamsDatum datum,
                                      Throwable e,
                                      Class<? extends StreamsOperation> operationClass)

Adds an error occurred during a StreamsOperation step to the StreamsDatum's metadata. By convention, errors are placed in the metadata under the "errors" and are organized by class simple name where the failure occurred.

Parameters:

datum - the datum on which the operation step errored

e - the error encountered

operationClass - the class of the operation

cloneDatum

public static StreamsDatum cloneDatum(StreamsDatum datum)