org.apache.hadoop.hive.ql.exec

Class FileSinkOperator.FSPaths

java.lang.Object

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

All Implemented Interfaces:

java.lang.Cloneable

Enclosing class:

FileSinkOperator

public class FileSinkOperator.FSPaths
extends java.lang.Object
implements java.lang.Cloneable

Constructor Summary

Constructors

Constructor and Description
FSPaths()
FSPaths(Path specPath)

Method Summary

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)

Methods inherited from class java.lang.Object

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

Constructor Detail

FSPaths

public FSPaths()

FSPaths

public FSPaths(Path specPath)

Method Detail

getTaskOutPath

public Path getTaskOutPath(java.lang.String taskId)

Update OutPath according to tmpPath.

getOutPath

public Path getOutPath(java.lang.String taskId)

Update OutPath according to tmpPath.

getOutPath

public Path getOutPath(java.lang.String taskId,
                       Path tmp)

Update OutPath according to tmpPath.

getFinalPath

public Path getFinalPath(java.lang.String taskId)

Update the final paths according to tmpPath.

getFinalPath

public Path getFinalPath(java.lang.String taskId,
                         Path tmpPath,
                         java.lang.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(FileSystem fs,
                         boolean abort,
                         boolean delete)
                  throws HiveException

Throws:

HiveException