T
- unusedpublic final class DeleteOldDataFn<T> extends Object implements org.apache.spark.api.java.function.VoidFunction<org.apache.spark.api.java.JavaRDD<T>>
Constructor and Description |
---|
DeleteOldDataFn(org.apache.hadoop.conf.Configuration hadoopConf,
String dataDirString,
Pattern dirTimestampPattern,
int maxAgeHours) |
public void call(org.apache.spark.api.java.JavaRDD<T> ignored) throws IOException
call
in interface org.apache.spark.api.java.function.VoidFunction<org.apache.spark.api.java.JavaRDD<T>>
IOException
Copyright © 2014–2016. All rights reserved.