public class FileSinkOperator.FSPaths extends Object implements Cloneable
Constructor and Description |
---|
FSPaths(org.apache.hadoop.fs.Path specPath) |
Modifier and Type | Method and Description |
---|---|
void |
abortWriters(org.apache.hadoop.fs.FileSystem fs,
boolean abort,
boolean delete) |
void |
closeWriters(boolean abort) |
org.apache.hadoop.fs.Path |
getFinalPath(String taskId,
org.apache.hadoop.fs.Path tmpPath,
String extension)
Update the final paths according to tmpPath.
|
Stat |
getStat() |
org.apache.hadoop.fs.Path |
getTaskOutPath(String taskId)
Update OutPath according to tmpPath.
|
public org.apache.hadoop.fs.Path getTaskOutPath(String taskId)
public org.apache.hadoop.fs.Path getFinalPath(String taskId, org.apache.hadoop.fs.Path tmpPath, String extension)
public void closeWriters(boolean abort) throws HiveException
HiveException
public void abortWriters(org.apache.hadoop.fs.FileSystem fs, boolean abort, boolean delete) throws HiveException
HiveException
public Stat getStat()
Copyright © 2016 The Apache Software Foundation. All rights reserved.