org.apache.hadoop.hive.ql.exec
Class FileSinkOperator.FSPaths

java.lang.Object
  org.apache.hadoop.hive.ql.exec.FileSinkOperator.FSPaths

All Implemented Interfaces:

Cloneable

Enclosing class:

FileSinkOperator

public class FileSinkOperator.FSPaths
extends Object
implements Cloneable

Constructor Summary

FileSinkOperator.FSPaths()

FileSinkOperator.FSPaths(org.apache.hadoop.fs.Path specPath)

Method Summary

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.
FileSinkOperator.RecordWriter[]	getOutWriters()
Stat	getStat()
org.apache.hadoop.fs.Path	getTaskOutPath(String taskId) Update OutPath according to tmpPath.
void	setOutWriters(FileSinkOperator.RecordWriter[] out)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

FileSinkOperator.FSPaths

public FileSinkOperator.FSPaths()

FileSinkOperator.FSPaths

public FileSinkOperator.FSPaths(org.apache.hadoop.fs.Path specPath)

Method Detail

getTaskOutPath

public org.apache.hadoop.fs.Path getTaskOutPath(String taskId)

Update OutPath according to tmpPath.

getFinalPath

public org.apache.hadoop.fs.Path getFinalPath(String taskId,
                                              org.apache.hadoop.fs.Path tmpPath,
                                              String extension)

Update the final paths according to tmpPath.

setOutWriters

public void setOutWriters(FileSinkOperator.RecordWriter[] out)

getOutWriters

public FileSinkOperator.RecordWriter[] getOutWriters()

closeWriters

public void closeWriters(boolean abort)
                  throws HiveException

Throws:

HiveException

abortWriters

public void abortWriters(org.apache.hadoop.fs.FileSystem fs,
                         boolean abort,
                         boolean delete)
                  throws HiveException

Throws:

HiveException

getStat

public Stat getStat()