Package org.apache.spark.sql.scripting

Class SingleStatementExec

Object
org.apache.spark.sql.scripting.SingleStatementExec
All Implemented Interfaces:
org.apache.spark.internal.Logging, org.apache.spark.sql.catalyst.trees.WithOrigin, CompoundStatementExec, LeafStatementExec
public class SingleStatementExec extends Object implements LeafStatementExec, org.apache.spark.sql.catalyst.trees.WithOrigin
Executable node for SingleStatement. param: parsedPlan Logical plan of the parsed statement. param: origin Origin descriptor for the statement. param: isInternal Whether the statement originates from the SQL script or it is created during the interpretation. Example: DropVariable statements are automatically created at the end of each compound.

  • Nested Class Summary

    Nested classes/interfaces inherited from interface org.apache.spark.internal.Logging

    org.apache.spark.internal.Logging.LogStringContext, org.apache.spark.internal.Logging.SparkShellLoggingFilter

  • Constructor Summary

    Constructors
    Constructor
    Description
    SingleStatementExec(org.apache.spark.sql.catalyst.plans.logical.LogicalPlan parsedPlan, org.apache.spark.sql.catalyst.trees.Origin origin, boolean isInternal)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    String
    getText()
    Get the SQL query text corresponding to this statement.
    boolean
    isExecuted()
    Whether this statement has been executed during the interpretation phase.
    boolean
    isInternal()
    Whether the statement originates from the SQL script or is created during the interpretation.
    org.apache.spark.sql.catalyst.trees.Origin
    origin()
     
    org.apache.spark.sql.catalyst.plans.logical.LogicalPlan
    parsedPlan()
     
    void
    reset()
    Reset execution of the current node.

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface org.apache.spark.internal.Logging

    initializeForcefully, initializeLogIfNecessary, initializeLogIfNecessary, initializeLogIfNecessary$default$2, isTraceEnabled, log, logDebug, logDebug, logDebug, logDebug, logError, logError, logError, logError, logInfo, logInfo, logInfo, logInfo, logName, LogStringContext, logTrace, logTrace, logTrace, logTrace, logWarning, logWarning, logWarning, logWarning, org$apache$spark$internal$Logging$$log_, org$apache$spark$internal$Logging$$log__$eq, withLogContext

  • Constructor Details

    • SingleStatementExec

      public SingleStatementExec(org.apache.spark.sql.catalyst.plans.logical.LogicalPlan parsedPlan, org.apache.spark.sql.catalyst.trees.Origin origin, boolean isInternal)

  • Method Details

    • getText

      public String getText()
      Get the SQL query text corresponding to this statement.
      Returns:
      SQL query text.

    • isExecuted

      public boolean isExecuted()
      Whether this statement has been executed during the interpretation phase. Example: Statements in conditions of If/Else, While, etc.
      Returns:
      (undocumented)

    • isInternal

      public boolean isInternal()
      Description copied from interface: CompoundStatementExec
      Whether the statement originates from the SQL script or is created during the interpretation. Example: DropVariable statements are automatically created at the end of each compound.
      Specified by:
      isInternal in interface CompoundStatementExec
      Returns:
      (undocumented)

    • origin

      public org.apache.spark.sql.catalyst.trees.Origin origin()
      Specified by:
      origin in interface org.apache.spark.sql.catalyst.trees.WithOrigin

    • parsedPlan

      public org.apache.spark.sql.catalyst.plans.logical.LogicalPlan parsedPlan()

    • reset

      public void reset()
      Description copied from interface: CompoundStatementExec
      Reset execution of the current node.
      Specified by:
      reset in interface CompoundStatementExec