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	appendTmpPath(String dp) Append a subdirectory to the tmp path.
void	closeWriters(boolean abort)
org.apache.hadoop.fs.Path	getFinalPath(String taskId) Update the final paths according to tmpPath.
org.apache.hadoop.fs.Path	getFinalPath(String taskId, org.apache.hadoop.fs.Path tmpPath, String extension) Update the final paths according to tmpPath.
org.apache.hadoop.fs.Path	getOutPath(String taskId) Update OutPath according to tmpPath.
org.apache.hadoop.fs.Path	getOutPath(String taskId, org.apache.hadoop.fs.Path tmp) Update OutPath according to tmpPath.
FileSinkOperator.RecordWriter[]	getOutWriters()
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

clone, equals, finalize, 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

appendTmpPath

public void appendTmpPath(String dp)

Append a subdirectory to the tmp path.

Parameters:

dp - subdirecgtory name

getTaskOutPath

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

Update OutPath according to tmpPath.

getOutPath

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

Update OutPath according to tmpPath.

getOutPath

public org.apache.hadoop.fs.Path getOutPath(String taskId,
                                            org.apache.hadoop.fs.Path tmp)

Update OutPath according to tmpPath.

getFinalPath

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

Update the final paths 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