public class FileSinkOperator.FSPaths extends Object implements Cloneable
Constructor and Description |
---|
FSPaths(org.apache.hadoop.fs.Path specPath,
boolean isMmTable) |
Modifier and Type | Method and Description |
---|---|
void |
abortWriters(org.apache.hadoop.fs.FileSystem fs,
boolean abort,
boolean delete) |
void |
addToStat(String statType,
long amount) |
org.apache.hadoop.fs.Path |
buildTaskOutputTempPath() |
org.apache.hadoop.fs.Path |
buildTmpPath() |
void |
closeWriters(boolean abort) |
int |
createDynamicBucket(int bucketNum)
This method is intended for use with ACID unbucketed tables, where the DELETE ops behave as
though they are bucketed, but without an explicit pre-specified bucket count.
|
Collection<String> |
getStoredStats() |
void |
initializeBucketPaths(int filesIdx,
String taskId,
boolean isNativeTable,
boolean isSkewedStoredAsSubDirectories) |
public void closeWriters(boolean abort) throws HiveException
HiveException
public void abortWriters(org.apache.hadoop.fs.FileSystem fs, boolean abort, boolean delete) throws HiveException
HiveException
public void initializeBucketPaths(int filesIdx, String taskId, boolean isNativeTable, boolean isSkewedStoredAsSubDirectories)
public org.apache.hadoop.fs.Path buildTmpPath()
public org.apache.hadoop.fs.Path buildTaskOutputTempPath()
public void addToStat(String statType, long amount)
public Collection<String> getStoredStats()
public int createDynamicBucket(int bucketNum)
Copyright © 2022 The Apache Software Foundation. All rights reserved.