|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.apache.hadoop.hive.ql.io.AcidOutputFormat.Options
public static class AcidOutputFormat.Options
Options to control how the files are written
Constructor Summary | |
---|---|
AcidOutputFormat.Options(org.apache.hadoop.conf.Configuration conf)
Create the options object. |
Method Summary | |
---|---|
AcidOutputFormat.Options |
bucket(int bucket)
The bucket that is included in this file. |
AcidOutputFormat.Options |
filesystem(org.apache.hadoop.fs.FileSystem fs)
Provide a file system to the writer. |
int |
getBucket()
|
org.apache.hadoop.conf.Configuration |
getConfiguration()
|
PrintStream |
getDummyStream()
|
org.apache.hadoop.fs.FileSystem |
getFilesystem()
|
ObjectInspector |
getInspector()
|
long |
getMaximumTransactionId()
|
long |
getMinimumTransactionId()
|
org.apache.hadoop.mapred.Reporter |
getReporter()
|
Properties |
getTableProperties()
|
AcidOutputFormat.Options |
inspector(ObjectInspector inspector)
Use the given ObjectInspector for each record written. |
boolean |
isCompressed()
|
AcidOutputFormat.Options |
isCompressed(boolean isCompressed)
Should the output be compressed? |
boolean |
isWritingBase()
|
AcidOutputFormat.Options |
maximumTransactionId(long max)
The maximum transaction id that is included in this file. |
AcidOutputFormat.Options |
minimumTransactionId(long min)
The minimum transaction id that is included in this file. |
AcidOutputFormat.Options |
reporter(org.apache.hadoop.mapred.Reporter reporter)
Provide the MapReduce reporter. |
AcidOutputFormat.Options |
tableProperties(Properties properties)
Provide the table properties for the table. |
AcidOutputFormat.Options |
useDummy(PrintStream stream)
Temporary switch while we are in development that replaces the implementation with a dummy one that just prints to stream. |
AcidOutputFormat.Options |
writingBase(boolean val)
Is this writing a base directory? Should only be used by the compactor, or when implementing insert overwrite. |
Methods inherited from class java.lang.Object |
---|
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public AcidOutputFormat.Options(org.apache.hadoop.conf.Configuration conf)
conf
- Use the given configurationMethod Detail |
---|
public AcidOutputFormat.Options inspector(ObjectInspector inspector)
inspector
- the inspector to use.
public AcidOutputFormat.Options writingBase(boolean val)
val
- is this a base file?
public AcidOutputFormat.Options filesystem(org.apache.hadoop.fs.FileSystem fs)
fs
- the file system that corresponds to the the path
public AcidOutputFormat.Options isCompressed(boolean isCompressed)
isCompressed
- is the output compressed?
public AcidOutputFormat.Options tableProperties(Properties properties)
properties
- the table's properties
public AcidOutputFormat.Options reporter(org.apache.hadoop.mapred.Reporter reporter)
reporter
- the reporter object
public AcidOutputFormat.Options minimumTransactionId(long min)
min
- minimum transaction id
public AcidOutputFormat.Options maximumTransactionId(long max)
max
- maximum transaction id
public AcidOutputFormat.Options bucket(int bucket)
bucket
- the bucket number
public AcidOutputFormat.Options useDummy(PrintStream stream)
stream
- the stream to print to
public org.apache.hadoop.conf.Configuration getConfiguration()
public org.apache.hadoop.fs.FileSystem getFilesystem()
public ObjectInspector getInspector()
public boolean isCompressed()
public Properties getTableProperties()
public org.apache.hadoop.mapred.Reporter getReporter()
public long getMinimumTransactionId()
public long getMaximumTransactionId()
public boolean isWritingBase()
public int getBucket()
public PrintStream getDummyStream()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |