OptimizedCreateHiveTableAsSelectCommand

Instance Constructors

new OptimizedCreateHiveTableAsSelectCommand(tableDesc: CatalogTable, query: LogicalPlan, outputColumnNames: Seq[String], mode: SaveMode)

tableDesc
the table description, which may contain serde, storage handler etc.
query
the query whose result will be insert into the new relation
mode
SaveMode

Value Members

final def !=(arg0: Any): Boolean

Definition Classes
AnyRef → Any
final def ##(): Int

Definition Classes
AnyRef → Any
final def ==(arg0: Any): Boolean

Definition Classes
AnyRef → Any
lazy val allAttributes: AttributeSeq

Definition Classes
QueryPlan
def analyzed: Boolean

Definition Classes
AnalysisHelper
def apply(number: Int): TreeNode[_]

Definition Classes
TreeNode
def argString: String

Definition Classes
CreateHiveTableAsSelectBase → TreeNode
def asCode: String

Definition Classes
TreeNode
final def asInstanceOf[T0]: T0

Definition Classes
Any
def assertNotAnalysisRule(): Unit

Attributes
protected
Definition Classes
AnalysisHelper
def basicWriteJobStatsTracker(hadoopConf: Configuration): BasicWriteJobStatsTracker

Definition Classes
DataWritingCommand
final lazy val canonicalized: LogicalPlan

Definition Classes
QueryPlan
final def children: Seq[LogicalPlan]

Definition Classes
DataWritingCommand → Command → TreeNode
def childrenResolved: Boolean

Definition Classes
LogicalPlan
def clone(): AnyRef

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( ... )
def collect[B](pf: PartialFunction[LogicalPlan, B]): Seq[B]

Definition Classes
TreeNode
def collectFirst[B](pf: PartialFunction[LogicalPlan, B]): Option[B]

Definition Classes
TreeNode
def collectLeaves(): Seq[LogicalPlan]

Definition Classes
TreeNode
def conf: SQLConf

Definition Classes
QueryPlan
lazy val constraints: ExpressionSet

Definition Classes
QueryPlanConstraints
def constructIsNotNullConstraints(constraints: Set[Expression], output: Seq[Attribute]): Set[Expression]

Definition Classes
ConstraintHelper
lazy val containsChild: Set[TreeNode[_]]

Definition Classes
TreeNode
def doCanonicalize(): LogicalPlan

Attributes
protected
Definition Classes
QueryPlan
final def eq(arg0: AnyRef): Boolean

Definition Classes
AnyRef
final def expressions: Seq[Expression]

Definition Classes
QueryPlan
def fastEquals(other: TreeNode[_]): Boolean

Definition Classes
TreeNode
def finalize(): Unit

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( classOf[java.lang.Throwable] )
def find(f: (LogicalPlan) ⇒ Boolean): Option[LogicalPlan]

Definition Classes
TreeNode
def flatMap[A](f: (LogicalPlan) ⇒ TraversableOnce[A]): Seq[A]

Definition Classes
TreeNode
def foreach(f: (LogicalPlan) ⇒ Unit): Unit

Definition Classes
TreeNode
def foreachUp(f: (LogicalPlan) ⇒ Unit): Unit

Definition Classes
TreeNode
def generateTreeString(depth: Int, lastChildren: Seq[Boolean], builder: StringBuilder, verbose: Boolean, prefix: String, addSuffix: Boolean): StringBuilder

Definition Classes
TreeNode
final def getClass(): Class[_]

Definition Classes
AnyRef → Any
def getWritingCommand(catalog: SessionCatalog, tableDesc: CatalogTable, tableExists: Boolean): DataWritingCommand

Definition Classes
OptimizedCreateHiveTableAsSelectCommand → CreateHiveTableAsSelectBase
def hashCode(): Int

Definition Classes
TreeNode → AnyRef → Any
def inferAdditionalConstraints(constraints: Set[Expression]): Set[Expression]

Definition Classes
ConstraintHelper
def initializeLogIfNecessary(isInterpreter: Boolean, silent: Boolean = false): Boolean

Attributes
protected
Definition Classes
Logging
def initializeLogIfNecessary(isInterpreter: Boolean): Unit

Attributes
protected
Definition Classes
Logging
def innerChildren: Seq[QueryPlan[_]]

Attributes
protected
Definition Classes
QueryPlan → TreeNode
def inputSet: AttributeSet

Definition Classes
QueryPlan
final def invalidateStatsCache(): Unit

Definition Classes
LogicalPlanStats
def isCanonicalizedPlan: Boolean

Attributes
protected
Definition Classes
QueryPlan
final def isInstanceOf[T0]: Boolean

Definition Classes
Any
def isStreaming: Boolean

Definition Classes
LogicalPlan
def isTraceEnabled(): Boolean

Attributes
protected
Definition Classes
Logging
def jsonFields: List[JField]

Attributes
protected
Definition Classes
TreeNode
def log: Logger

Attributes
protected
Definition Classes
Logging
def logDebug(msg: ⇒ String, throwable: Throwable): Unit

Attributes
protected
Definition Classes
Logging
def logDebug(msg: ⇒ String): Unit

Attributes
protected
Definition Classes
Logging
def logError(msg: ⇒ String, throwable: Throwable): Unit

Attributes
protected
Definition Classes
Logging
def logError(msg: ⇒ String): Unit

Attributes
protected
Definition Classes
Logging
def logInfo(msg: ⇒ String, throwable: Throwable): Unit

Attributes
protected
Definition Classes
Logging
def logInfo(msg: ⇒ String): Unit

Attributes
protected
Definition Classes
Logging
def logName: String

Attributes
protected
Definition Classes
Logging
def logTrace(msg: ⇒ String, throwable: Throwable): Unit

Attributes
protected
Definition Classes
Logging
def logTrace(msg: ⇒ String): Unit

Attributes
protected
Definition Classes
Logging
def logWarning(msg: ⇒ String, throwable: Throwable): Unit

Attributes
protected
Definition Classes
Logging
def logWarning(msg: ⇒ String): Unit

Attributes
protected
Definition Classes
Logging
def makeCopy(newArgs: Array[AnyRef]): LogicalPlan

Definition Classes
TreeNode
def map[A](f: (LogicalPlan) ⇒ A): Seq[A]

Definition Classes
TreeNode
def mapChildren(f: (LogicalPlan) ⇒ LogicalPlan): LogicalPlan

Definition Classes
TreeNode
def mapExpressions(f: (Expression) ⇒ Expression): OptimizedCreateHiveTableAsSelectCommand.this.type

Definition Classes
QueryPlan
def mapProductIterator[B](f: (Any) ⇒ B)(implicit arg0: ClassTag[B]): Array[B]

Attributes
protected
Definition Classes
TreeNode
def maxRows: Option[Long]

Definition Classes
LogicalPlan
def maxRowsPerPartition: Option[Long]

Definition Classes
LogicalPlan
lazy val metrics: Map[String, SQLMetric]

Definition Classes
DataWritingCommand
def missingInput: AttributeSet

Definition Classes
QueryPlan
val mode: SaveMode

SaveMode
SaveMode

Definition Classes
OptimizedCreateHiveTableAsSelectCommand → CreateHiveTableAsSelectBase
final def ne(arg0: AnyRef): Boolean

Definition Classes
AnyRef
def nodeName: String

Definition Classes
TreeNode
final def notify(): Unit

Definition Classes
AnyRef
final def notifyAll(): Unit

Definition Classes
AnyRef
def numberedTreeString: String

Definition Classes
TreeNode
val origin: Origin

Definition Classes
TreeNode
def otherCopyArgs: Seq[AnyRef]

Attributes
protected
Definition Classes
TreeNode
def output: Seq[Attribute]

Definition Classes
Command → QueryPlan
val outputColumnNames: Seq[String]

Definition Classes
OptimizedCreateHiveTableAsSelectCommand → CreateHiveTableAsSelectBase → DataWritingCommand
def outputColumns: Seq[Attribute]

Definition Classes
DataWritingCommand
def outputOrdering: Seq[SortOrder]

Definition Classes
LogicalPlan
def outputSet: AttributeSet

Definition Classes
QueryPlan
def p(number: Int): LogicalPlan

Definition Classes
TreeNode
def prettyJson: String

Definition Classes
TreeNode
def printSchema(): Unit

Definition Classes
QueryPlan
def producedAttributes: AttributeSet

Definition Classes
QueryPlan
val query: LogicalPlan

the query whose result will be insert into the new relation
the query whose result will be insert into the new relation

Definition Classes
OptimizedCreateHiveTableAsSelectCommand → CreateHiveTableAsSelectBase → DataWritingCommand
def references: AttributeSet

Definition Classes
QueryPlan
def refresh(): Unit

Definition Classes
LogicalPlan
def resolve(nameParts: Seq[String], resolver: Resolver): Option[NamedExpression]

Definition Classes
LogicalPlan
def resolve(schema: StructType, resolver: Resolver): Seq[Attribute]

Definition Classes
LogicalPlan
def resolveChildren(nameParts: Seq[String], resolver: Resolver): Option[NamedExpression]

Definition Classes
LogicalPlan
def resolveExpressions(r: PartialFunction[Expression, Expression]): LogicalPlan

Definition Classes
AnalysisHelper
def resolveOperators(rule: PartialFunction[LogicalPlan, LogicalPlan]): LogicalPlan

Definition Classes
AnalysisHelper
def resolveOperatorsDown(rule: PartialFunction[LogicalPlan, LogicalPlan]): LogicalPlan

Definition Classes
AnalysisHelper
def resolveOperatorsUp(rule: PartialFunction[LogicalPlan, LogicalPlan]): LogicalPlan

Definition Classes
AnalysisHelper
def resolveQuoted(name: String, resolver: Resolver): Option[NamedExpression]

Definition Classes
LogicalPlan
lazy val resolved: Boolean

Definition Classes
LogicalPlan
def run(sparkSession: SparkSession, child: SparkPlan): Seq[Row]

Definition Classes
CreateHiveTableAsSelectBase → DataWritingCommand
final def sameResult(other: LogicalPlan): Boolean

Definition Classes
QueryPlan
lazy val schema: StructType

Definition Classes
QueryPlan
def schemaString: String

Definition Classes
QueryPlan
final def semanticHash(): Int

Definition Classes
QueryPlan
def simpleString: String

Definition Classes
QueryPlan → TreeNode
def statePrefix: String

Attributes
protected
Definition Classes
LogicalPlan → QueryPlan
def stats: Statistics

Definition Classes
LogicalPlanStats
var statsCache: Option[Statistics]

Attributes
protected
Definition Classes
LogicalPlanStats
def stringArgs: Iterator[Any]

Attributes
protected
Definition Classes
TreeNode
def subqueries: Seq[LogicalPlan]

Definition Classes
QueryPlan
final def synchronized[T0](arg0: ⇒ T0): T0

Definition Classes
AnyRef
val tableDesc: CatalogTable

the table description, which may contain serde, storage handler etc.
the table description, which may contain serde, storage handler etc.

Definition Classes
OptimizedCreateHiveTableAsSelectCommand → CreateHiveTableAsSelectBase
val tableIdentifier: TableIdentifier

Attributes
protected
Definition Classes
CreateHiveTableAsSelectBase
def toJSON: String

Definition Classes
TreeNode
def toString(): String

Definition Classes
TreeNode → AnyRef → Any
def transform(rule: PartialFunction[LogicalPlan, LogicalPlan]): LogicalPlan

Definition Classes
TreeNode
def transformAllExpressions(rule: PartialFunction[Expression, Expression]): OptimizedCreateHiveTableAsSelectCommand.this.type

Definition Classes
AnalysisHelper → QueryPlan
def transformDown(rule: PartialFunction[LogicalPlan, LogicalPlan]): LogicalPlan

Definition Classes
AnalysisHelper → TreeNode
def transformExpressions(rule: PartialFunction[Expression, Expression]): OptimizedCreateHiveTableAsSelectCommand.this.type

Definition Classes
QueryPlan
def transformExpressionsDown(rule: PartialFunction[Expression, Expression]): OptimizedCreateHiveTableAsSelectCommand.this.type

Definition Classes
QueryPlan
def transformExpressionsUp(rule: PartialFunction[Expression, Expression]): OptimizedCreateHiveTableAsSelectCommand.this.type

Definition Classes
QueryPlan
def transformUp(rule: PartialFunction[LogicalPlan, LogicalPlan]): LogicalPlan

Definition Classes
AnalysisHelper → TreeNode
def treeString(verbose: Boolean, addSuffix: Boolean): String

Definition Classes
TreeNode
def treeString: String

Definition Classes
TreeNode
def validConstraints: Set[Expression]

Attributes
protected
Definition Classes
QueryPlanConstraints
def verboseString: String

Definition Classes
QueryPlan → TreeNode
def verboseStringWithSuffix: String

Definition Classes
LogicalPlan → TreeNode
final def wait(): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(arg0: Long, arg1: Int): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(arg0: Long): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
def withNewChildren(newChildren: Seq[LogicalPlan]): LogicalPlan

Definition Classes
TreeNode

Related Doc: package execution

case class OptimizedCreateHiveTableAsSelectCommand(tableDesc: CatalogTable, query: LogicalPlan, outputColumnNames: Seq[String], mode: SaveMode) extends LogicalPlan with CreateHiveTableAsSelectBase with Product with Serializable

Instance Constructors

new OptimizedCreateHiveTableAsSelectCommand(tableDesc: CatalogTable, query: LogicalPlan, outputColumnNames: Seq[String], mode: SaveMode)

Value Members

final def !=(arg0: Any): Boolean

final def ##(): Int

final def ==(arg0: Any): Boolean

lazy val allAttributes: AttributeSeq

def analyzed: Boolean

def apply(number: Int): TreeNode[_]

def argString: String

def asCode: String

final def asInstanceOf[T0]: T0

def assertNotAnalysisRule(): Unit

def basicWriteJobStatsTracker(hadoopConf: Configuration): BasicWriteJobStatsTracker

final lazy val canonicalized: LogicalPlan

final def children: Seq[LogicalPlan]

def childrenResolved: Boolean

def clone(): AnyRef

def collect[B](pf: PartialFunction[LogicalPlan, B]): Seq[B]

def collectFirst[B](pf: PartialFunction[LogicalPlan, B]): Option[B]

def collectLeaves(): Seq[LogicalPlan]

def conf: SQLConf

lazy val constraints: ExpressionSet

def constructIsNotNullConstraints(constraints: Set[Expression], output: Seq[Attribute]): Set[Expression]

lazy val containsChild: Set[TreeNode[_]]

def doCanonicalize(): LogicalPlan

final def eq(arg0: AnyRef): Boolean

final def expressions: Seq[Expression]

def fastEquals(other: TreeNode[_]): Boolean

def finalize(): Unit

def find(f: (LogicalPlan) ⇒ Boolean): Option[LogicalPlan]

def flatMap[A](f: (LogicalPlan) ⇒ TraversableOnce[A]): Seq[A]

def foreach(f: (LogicalPlan) ⇒ Unit): Unit

def foreachUp(f: (LogicalPlan) ⇒ Unit): Unit

def generateTreeString(depth: Int, lastChildren: Seq[Boolean], builder: StringBuilder, verbose: Boolean, prefix: String, addSuffix: Boolean): StringBuilder

final def getClass(): Class[_]

def getWritingCommand(catalog: SessionCatalog, tableDesc: CatalogTable, tableExists: Boolean): DataWritingCommand

def hashCode(): Int

def inferAdditionalConstraints(constraints: Set[Expression]): Set[Expression]

def initializeLogIfNecessary(isInterpreter: Boolean, silent: Boolean = false): Boolean

def initializeLogIfNecessary(isInterpreter: Boolean): Unit

def innerChildren: Seq[QueryPlan[_]]

def inputSet: AttributeSet

final def invalidateStatsCache(): Unit

def isCanonicalizedPlan: Boolean

final def isInstanceOf[T0]: Boolean

def isStreaming: Boolean

def isTraceEnabled(): Boolean

def jsonFields: List[JField]

def log: Logger

def logDebug(msg: ⇒ String, throwable: Throwable): Unit

def logDebug(msg: ⇒ String): Unit

def logError(msg: ⇒ String, throwable: Throwable): Unit

def logError(msg: ⇒ String): Unit

def logInfo(msg: ⇒ String, throwable: Throwable): Unit

def logInfo(msg: ⇒ String): Unit

def logName: String

def logTrace(msg: ⇒ String, throwable: Throwable): Unit

def logTrace(msg: ⇒ String): Unit

def logWarning(msg: ⇒ String, throwable: Throwable): Unit

def logWarning(msg: ⇒ String): Unit

def makeCopy(newArgs: Array[AnyRef]): LogicalPlan

def map[A](f: (LogicalPlan) ⇒ A): Seq[A]

def mapChildren(f: (LogicalPlan) ⇒ LogicalPlan): LogicalPlan

def mapExpressions(f: (Expression) ⇒ Expression): OptimizedCreateHiveTableAsSelectCommand.this.type

def mapProductIterator[B](f: (Any) ⇒ B)(implicit arg0: ClassTag[B]): Array[B]

def maxRows: Option[Long]

def maxRowsPerPartition: Option[Long]

lazy val metrics: Map[String, SQLMetric]

def missingInput: AttributeSet

val mode: SaveMode

final def ne(arg0: AnyRef): Boolean

def nodeName: String

final def notify(): Unit

final def notifyAll(): Unit

def numberedTreeString: String

val origin: Origin