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

Constructors

Constructor and Description
FileSinkOperator.FSPaths(org.apache.hadoop.fs.Path specPath)

Method Summary

Methods

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.
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

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

Constructor Detail

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()