org.thales.punch.libraries.storm.util

Class ArchiveUtils

java.lang.Object

org.thales.punch.libraries.storm.util.ArchiveUtils

public final class ArchiveUtils
extends Object

Method Summary

Modifier and Type	Method and Description
static void	fatalException(Exception e) Log a fatal exception and exit.
static Long	getLongField(org.apache.storm.tuple.ITuple tuple, String field, Long defaultValue)
static Integer	getMandatoryIntegerField(org.apache.storm.tuple.ITuple tuple, String field) Fast fail if a mandatory integer field is missing.
static Long	getMandatoryLongField(org.apache.storm.tuple.ITuple tuple, String field) Fast fail if a mandatory long field is missing.

Methods inherited from class java.lang.Object

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

Method Detail

getMandatoryLongField

public static Long getMandatoryLongField(org.apache.storm.tuple.ITuple tuple,
                                         String field)

Fast fail if a mandatory long field is missing.

Parameters:

tuple - the incoming tuple

field - the required field

Returns:

Long value of field

getLongField

public static Long getLongField(org.apache.storm.tuple.ITuple tuple,
                                String field,
                                Long defaultValue)

getMandatoryIntegerField

public static Integer getMandatoryIntegerField(org.apache.storm.tuple.ITuple tuple,
                                               String field)

Fast fail if a mandatory integer field is missing.

Parameters:

tuple - the incoming tuple

field - the required field

Returns:

Integer value of field

fatalException

public static void fatalException(Exception e)

Log a fatal exception and exit. By design in case of archiving error we simply exits. This is the best and only bullet proof strategy to deal with at least or exactly once archiving.

Parameters:

e - Exception raised