com.cloudera.oryx.lambda

Class DeleteOldDataFn<T>

java.lang.Object

com.cloudera.oryx.lambda.DeleteOldDataFn<T>

Type Parameters:

T - unused

All Implemented Interfaces:

Serializable, org.apache.spark.api.java.function.VoidFunction<T>

public final class DeleteOldDataFn<T>
extends Object
implements org.apache.spark.api.java.function.VoidFunction<T>

Function that deletes old data, if applicable, at each batch interval.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
DeleteOldDataFn(org.apache.hadoop.conf.Configuration hadoopConf, String dataDirString, Pattern dirTimestampPattern, int maxAgeHours)

Method Summary

Modifier and Type	Method and Description
void	call(T ignored)

Methods inherited from class java.lang.Object

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

Constructor Detail

DeleteOldDataFn

public DeleteOldDataFn(org.apache.hadoop.conf.Configuration hadoopConf,
                       String dataDirString,
                       Pattern dirTimestampPattern,
                       int maxAgeHours)

Method Detail

call

public void call(T ignored)
          throws IOException

Specified by:

call in interface org.apache.spark.api.java.function.VoidFunction<T>

Throws:

IOException