org.apache.spark.sql.hive

Class ShimFileSinkDesc

Object

org.apache.spark.sql.hive.ShimFileSinkDesc

All Implemented Interfaces:

java.io.Serializable, Logging

public class ShimFileSinkDesc
extends Object
implements scala.Serializable, Logging

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ShimFileSinkDesc(String dir, org.apache.hadoop.hive.ql.plan.TableDesc tableInfo, boolean compressed)

Method Summary

Methods

Modifier and Type	Method and Description
String	compressCodec()
boolean	compressed()
String	compressType()
int	destTableId()
String	dir()
String	getDirName()
void	setCompressCodec(String intermediateCompressorCodec)
void	setCompressed(boolean compressed)
void	setCompressType(String intermediateCompressType)
void	setDestTableId(int destTableId)
void	setTableInfo(org.apache.hadoop.hive.ql.plan.TableDesc tableInfo)
org.apache.hadoop.hive.ql.plan.TableDesc	tableInfo()

Methods inherited from class Object

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

Methods inherited from interface org.apache.spark.Logging

initializeIfNecessary, initializeLogging, isTraceEnabled, log_, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning

Constructor Detail

ShimFileSinkDesc

public ShimFileSinkDesc(String dir,
                org.apache.hadoop.hive.ql.plan.TableDesc tableInfo,
                boolean compressed)

Method Detail

dir

public String dir()

tableInfo

public org.apache.hadoop.hive.ql.plan.TableDesc tableInfo()

compressed

public boolean compressed()

compressCodec

public String compressCodec()

compressType

public String compressType()

destTableId

public int destTableId()

setCompressed

public void setCompressed(boolean compressed)

getDirName

public String getDirName()

setDestTableId

public void setDestTableId(int destTableId)

setTableInfo

public void setTableInfo(org.apache.hadoop.hive.ql.plan.TableDesc tableInfo)

setCompressCodec

public void setCompressCodec(String intermediateCompressorCodec)

setCompressType

public void setCompressType(String intermediateCompressType)