com.cloudera.oryx.lambda

Class HadoopUtils

java.lang.Object

com.cloudera.oryx.lambda.HadoopUtils

public final class HadoopUtils
extends Object

Hadoop-related utility methods.

Method Summary

Modifier and Type	Method and Description
static void	closeAtShutdown(Closeable closeable) Adds a shutdown hook that tries to call Closeable.close() on the given argument at JVM shutdown.

Methods inherited from class java.lang.Object

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

Method Detail

closeAtShutdown

public static void closeAtShutdown(Closeable closeable)

Adds a shutdown hook that tries to call Closeable.close() on the given argument at JVM shutdown. This integrates with Hadoop's ShutdownHookManager in order to better interact with Spark's usage of the same.

Parameters:

closeable - thing to close