Modifier and Type | Method and Description |
---|---|
static FileUtils.FileCopyResult |
CompressionUtils.gunzip(com.google.common.io.ByteSource in,
File outFile)
Gunzip from the input stream to the output file
|
static FileUtils.FileCopyResult |
CompressionUtils.gunzip(com.google.common.io.ByteSource in,
File outFile,
com.google.common.base.Predicate<Throwable> shouldRetry)
A gunzip function to store locally
|
static FileUtils.FileCopyResult |
CompressionUtils.gunzip(File pulledFile,
File outFile)
gunzip the file to the output file.
|
static FileUtils.FileCopyResult |
CompressionUtils.gunzip(InputStream in,
File outFile)
Unzips the input stream via a gzip filter.
|
static FileUtils.FileCopyResult |
CompressionUtils.gzip(File inFile,
File outFile)
GZip compress the contents of inFile into outFile
|
static FileUtils.FileCopyResult |
CompressionUtils.gzip(File inFile,
File outFile,
com.google.common.base.Predicate<Throwable> shouldRetry)
Gzips the input file to the output
|
static FileUtils.FileCopyResult |
FileUtils.retryCopy(com.google.common.io.ByteSource byteSource,
File outFile,
com.google.common.base.Predicate<Throwable> shouldRetry,
int maxAttempts)
Copy input byte source to outFile.
|
static FileUtils.FileCopyResult |
CompressionUtils.unzip(com.google.common.io.ByteSource byteSource,
File outDir,
boolean cacheLocally)
Unzip the byteSource to the output directory.
|
static FileUtils.FileCopyResult |
CompressionUtils.unzip(com.google.common.io.ByteSource byteSource,
File outDir,
com.google.common.base.Predicate<Throwable> shouldRetry,
boolean cacheLocally)
Unzip the byteSource to the output directory.
|
static FileUtils.FileCopyResult |
CompressionUtils.unzip(File pulledFile,
File outDir)
Unzip the pulled file to an output directory.
|
static FileUtils.FileCopyResult |
CompressionUtils.unzip(InputStream in,
File outDir)
Unzip from the input stream to the output directory, using the entry's file name as the file name in the output directory.
|
Modifier and Type | Method and Description |
---|---|
FileUtils.FileCopyResult |
LocalDataSegmentPuller.getSegmentFiles(File sourceFile,
File dir) |
Modifier and Type | Method and Description |
---|---|
FileUtils.FileCopyResult |
AzureDataSegmentPuller.getSegmentFiles(String containerName,
String blobPath,
File outDir) |
Modifier and Type | Method and Description |
---|---|
FileUtils.FileCopyResult |
CassandraDataSegmentPuller.getSegmentFiles(String key,
File outDir) |
Modifier and Type | Method and Description |
---|---|
FileUtils.FileCopyResult |
CloudFilesDataSegmentPuller.getSegmentFiles(String region,
String container,
String path,
File outDir) |
Modifier and Type | Method and Description |
---|---|
FileUtils.FileCopyResult |
GoogleDataSegmentPuller.getSegmentFiles(String bucket,
String path,
File outDir) |
Modifier and Type | Method and Description |
---|---|
FileUtils.FileCopyResult |
HdfsDataSegmentPuller.getSegmentFiles(org.apache.hadoop.fs.Path path,
File outDir) |
FileUtils.FileCopyResult |
HdfsDataSegmentPuller.getSegmentFiles(URI uri,
File outDir) |
Modifier and Type | Method and Description |
---|---|
FileUtils.FileCopyResult |
S3DataSegmentPuller.getSegmentFiles(S3DataSegmentPuller.S3Coords s3Coords,
File outDir) |
Copyright © 2011–2017. All rights reserved.