Class

org.apache.spark.sql.hive

SnappySessionState

Related Doc: package hive

Permalink

class SnappySessionState extends SessionState with SnappyStrategies

Holds all session-specific state for a given SnappySession.

Linear Supertypes
SnappyStrategies, SessionState, AnyRef, Any
Known Subclasses
SnappyAQPSessionState
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. SnappySessionState
  2. SnappyStrategies
  3. SessionState
  4. AnyRef
  5. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new SnappySessionState(snappySession: SnappySession)

    Permalink

Type Members

  1. case class AnalyzeMutableOperations(session: SnappySession, analyzer: Analyzer) extends Rule[LogicalPlan] with PredicateHelper with Product with Serializable

    Permalink

  2. final class LinkPartitionsToBuckets extends Rule[LogicalPlan]

    Permalink

    This rule sets the flag at query level to link the partitions to be created for tables to be the same as number of buckets.

    This rule sets the flag at query level to link the partitions to be created for tables to be the same as number of buckets. This will avoid exchange on one side of a non-collocated join in many cases.

Value Members

  1. final def !=(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any

  2. final def ##(): Int

    Permalink
    Definition Classes
    AnyRef → Any

  3. final def ==(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any

  4. object ExternalRelationLimitFetch extends Rule[LogicalPlan]

    Permalink

  5. object HashJoinStrategies extends Strategy with JoinQueryPlanning

    Permalink
    Definition Classes
    SnappyStrategies

  6. object OrderJoinConditions extends Rule[LogicalPlan] with JoinQueryPlanning

    Permalink

    Orders the join keys as per the underlying partitioning keys ordering of the table.

  7. object PushDownWindowLogicalPlan extends Rule[LogicalPlan]

    Permalink

  8. object ResolveAliasInGroupBy extends Rule[LogicalPlan]

    Permalink

  9. object RowLevelSecurity extends Rule[LogicalPlan]

    Permalink

  10. object SnappyAggregation extends Strategy

    Permalink
    Definition Classes
    SnappyStrategies

  11. object SnappyStrategies extends Strategy

    Permalink
    Definition Classes
    SnappyStrategies

  12. object StreamQueryStrategy extends Strategy

    Permalink

    Stream related strategies to map stream specific logical plan to physical plan

    Stream related strategies to map stream specific logical plan to physical plan

    Definition Classes
    SnappyStrategies

  13. object TokenizedLiteralFolding extends Rule[LogicalPlan]

    Permalink

  14. def addJar(path: String): Unit

    Permalink
    Definition Classes
    SessionState

  15. def analyze(tableIdent: TableIdentifier, noscan: Boolean = true): Unit

    Permalink

    Analyzes the given table in the current database to generate statistics, which will be used in query optimizations.

    Analyzes the given table in the current database to generate statistics, which will be used in query optimizations.

    Definition Classes
    SessionState

  16. lazy val analyzer: Analyzer

    Permalink

    Logical query plan analyzer for resolving unresolved attributes and relations.

    Logical query plan analyzer for resolving unresolved attributes and relations.

    Definition Classes
    SnappySessionState → SessionState

  17. final def asInstanceOf[T0]: T0

    Permalink
    Definition Classes
    Any

  18. def beforeExecutePlan(plan: LogicalPlan): Unit

    Permalink
    Attributes
    protected

  19. lazy val catalog: SnappySessionCatalog

    Permalink

    Internal catalog for managing table and database states.

    Internal catalog for managing table and database states.

    Definition Classes
    SnappySessionState → SessionState

  20. def clone(): AnyRef

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  21. lazy val conf: SnappyConf

    Permalink

    SQL-specific key-value configurations.

    SQL-specific key-value configurations.

    Definition Classes
    SnappySessionState → SessionState

  22. val contextFunctions: SnappyContextFunctions

    Permalink

  23. final def eq(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef

  24. def equals(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any

  25. final def executePlan(plan: LogicalPlan): QueryExecution

    Permalink
    Definition Classes
    SnappySessionState → SessionState

  26. final lazy val executionCache: ConcurrentHashMap[LogicalPlan, QueryExecution]

    Permalink
    Attributes
    protected

  27. lazy val experimentalMethods: ExperimentalMethods

    Permalink
    Definition Classes
    SessionState

  28. def finalize(): Unit

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )

  29. lazy val functionRegistry: FunctionRegistry

    Permalink

    Internal catalog for managing functions registered by the user.

    Internal catalog for managing functions registered by the user.

    Definition Classes
    SessionState

  30. lazy val functionResourceLoader: FunctionResourceLoader

    Permalink

    A class for loading resources specified by a function.

    A class for loading resources specified by a function.

    Definition Classes
    SessionState

  31. final def getClass(): Class[_]

    Permalink
    Definition Classes
    AnyRef → Any

  32. def getExtendedCheckRules: Seq[(LogicalPlan) ⇒ Unit]

    Permalink

  33. def getExtendedResolutionRules(analyzer: Analyzer): Seq[Rule[LogicalPlan]]

    Permalink

  34. def getTablePartitions(region: CacheDistributionAdvisee): Array[Partition]

    Permalink

  35. def getTablePartitions(region: PartitionedRegion): Array[Partition]

    Permalink

  36. def hashCode(): Int

    Permalink
    Definition Classes
    AnyRef → Any

  37. def isDisabled: Boolean

    Permalink
    Definition Classes
    SnappyStrategies

  38. final def isInstanceOf[T0]: Boolean

    Permalink
    Definition Classes
    Any

  39. var jdbcQueryJobGroupId: Option[String]

    Permalink

  40. lazy val listenerManager: ExecutionListenerManager

    Permalink

    An interface to register custom org.apache.spark.sql.util.QueryExecutionListeners that listen for execution metrics.

    An interface to register custom org.apache.spark.sql.util.QueryExecutionListeners that listen for execution metrics.

    Definition Classes
    SessionState

  41. final def ne(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef

  42. def newHadoopConf(): Configuration

    Permalink
    Definition Classes
    SessionState

  43. def newHadoopConfWithOptions(options: Map[String, String]): Configuration

    Permalink
    Definition Classes
    SessionState

  44. def newQueryExecution(plan: LogicalPlan): QueryExecution

    Permalink
    Attributes
    protected

  45. final def notify(): Unit

    Permalink
    Definition Classes
    AnyRef

  46. final def notifyAll(): Unit

    Permalink
    Definition Classes
    AnyRef

  47. lazy val optimizer: Optimizer

    Permalink

    Logical query plan optimizer.

    Logical query plan optimizer.

    Definition Classes
    SnappySessionState → SessionState

  48. def planner: SparkPlanner

    Permalink

    Planner that converts optimized logical plans to physical plans.

    Planner that converts optimized logical plans to physical plans.

    Definition Classes
    SessionState

  49. def queryPreparations(topLevel: Boolean): Seq[Rule[SparkPlan]]

    Permalink
    Attributes
    protected[org.apache.spark.sql]

  50. def refreshTable(tableName: String): Unit

    Permalink
    Definition Classes
    SessionState

  51. def registerStreamingQueryListener(streamingQueryListener: StreamingQueryListener): Unit

    Permalink
    Definition Classes
    SessionState

  52. def removeStreamingQueryListener(): Unit

    Permalink
    Definition Classes
    SessionState

  53. val sampleSnappyCase: PartialFunction[LogicalPlan, Seq[SparkPlan]]

    Permalink

  54. val snappySession: SnappySession

    Permalink

  55. lazy val sqlParser: SnappySqlParser

    Permalink

    Parser that extracts expressions, plans, table identifiers etc.

    Parser that extracts expressions, plans, table identifiers etc. from SQL texts.

    Definition Classes
    SnappySessionState → SessionState

  56. lazy val streamingQueryManager: StreamingQueryManager

    Permalink

    Interface to start and stop StreamingQuerys.

    Interface to start and stop StreamingQuerys.

    Definition Classes
    SnappySessionState → SessionState

  57. final def synchronized[T0](arg0: ⇒ T0): T0

    Permalink
    Definition Classes
    AnyRef

  58. def toString(): String

    Permalink
    Definition Classes
    AnyRef → Any

  59. lazy val udf: UDFRegistration

    Permalink

    Interface exposed to the user for registering user-defined functions.

    Interface exposed to the user for registering user-defined functions. Note that the user-defined functions must be deterministic.

    Definition Classes
    SessionState

  60. final def wait(): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  61. final def wait(arg0: Long, arg1: Int): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  62. final def wait(arg0: Long): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  63. lazy val wrapperCatalog: SessionCatalogWrapper

    Permalink
    Attributes
    protected

Inherited from SnappyStrategies

Inherited from SessionState

Inherited from AnyRef

Inherited from Any

Ungrouped