> From: "Gan, Xiyun" <[email protected]>
> I still have another question, how to remove the partitions_$timpstamp
> files produced in the HFileOutputFormat?
One option is to accept a configuration option for the partitions file:
- Path partitionsPath = new Path(job.getWorkingDirectory(),
- "partitions_" + System.currentTimeMillis());
+ Path partitionsPath = new Path(job.getConfiguration()
+ .get("hbase.hfileoutputformat.partitions.file",
+ "partitions_" + System.currentTimeMillis()));
Then you can configure the job with a path you know, and use the path to delete
the file after the job completes.
- Andy
Problems worthy of attack prove their worth by hitting back. - Piet Hein (via
Tom White)