public class FileSinkOperator.FSPaths
extends java.lang.Object
implements java.lang.Cloneable
Modifier and Type | Method and Description |
---|---|
void |
abortWriters(FileSystem fs,
boolean abort,
boolean delete) |
void |
closeWriters(boolean abort) |
Path |
getFinalPath(java.lang.String taskId)
Update the final paths according to tmpPath.
|
Path |
getFinalPath(java.lang.String taskId,
Path tmpPath,
java.lang.String extension)
Update the final paths according to tmpPath.
|
Path |
getOutPath(java.lang.String taskId)
Update OutPath according to tmpPath.
|
Path |
getOutPath(java.lang.String taskId,
Path tmp)
Update OutPath according to tmpPath.
|
FileSinkOperator.RecordWriter[] |
getOutWriters() |
Path |
getTaskOutPath(java.lang.String taskId)
Update OutPath according to tmpPath.
|
void |
setOutWriters(FileSinkOperator.RecordWriter[] out) |
public Path getTaskOutPath(java.lang.String taskId)
public Path getOutPath(java.lang.String taskId)
public Path getOutPath(java.lang.String taskId, Path tmp)
public Path getFinalPath(java.lang.String taskId)
public Path getFinalPath(java.lang.String taskId, Path tmpPath, java.lang.String extension)
public void setOutWriters(FileSinkOperator.RecordWriter[] out)
public FileSinkOperator.RecordWriter[] getOutWriters()
public void closeWriters(boolean abort) throws HiveException
HiveException
public void abortWriters(FileSystem fs, boolean abort, boolean delete) throws HiveException
HiveException
Copyright © 2012 The Apache Software Foundation