klotz: gzip*

Bookmarks on this page are managed by an admin user.

0 bookmark(s) - Sort by: Date ↓ / Title / - Bookmarks from other users for this tag

  1. sc.parallelize(fs.listStatus(...).map(_.getPath.toString)).map { pathStr =>
    val path = new Path(pathStr)
    val in = new GZIPInputStream(fs.open(path))
    try {
    in.read()
    } catch {
    case e: ZipException => fs.delete(path, false)
    } finally {
    in.close()
    }
    }
    2017-06-05 Tags: , , by klotz

Top of the page

First / Previous / Next / Last / Page 1 of 0 SemanticScuttle - klotz.me: Tags: gzip

About - Propulsed by SemanticScuttle