SnappyAQPSessionState

Instance Constructors

new SnappyAQPSessionState(_snappySession: SnappySession)

Type Members

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

Definition Classes
SnappySessionState
final class LinkPartitionsToBuckets extends Rule[LogicalPlan]

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.

Definition Classes
SnappySessionState

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
object ExternalRelationLimitFetch extends Rule[LogicalPlan]

Definition Classes
SnappySessionState
object HashJoinStrategies extends Strategy with JoinQueryPlanning

Definition Classes
SnappyStrategies
object OrderJoinConditions extends Rule[LogicalPlan] with JoinQueryPlanning

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

Definition Classes
SnappySessionState
object PushDownWindowLogicalPlan extends Rule[LogicalPlan]

Definition Classes
SnappySessionState
object ResolveAliasInGroupBy extends Rule[LogicalPlan]

Definition Classes
SnappySessionState
object RowLevelSecurity extends Rule[LogicalPlan]

Definition Classes
SnappySessionState
object SnappyAggregation extends Strategy

Definition Classes
SnappyStrategies
object SnappyStrategies extends Strategy

Definition Classes
SnappyStrategies
object StreamQueryStrategy extends Strategy

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
object TokenizedLiteralFolding extends Rule[LogicalPlan]

Definition Classes
SnappySessionState
def addJar(path: String): Unit

Definition Classes
SessionState
def analyze(tableIdent: TableIdentifier, noscan: Boolean = true): Unit

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
lazy val analyzer: Analyzer

Logical query plan analyzer for resolving unresolved attributes and relations.
Logical query plan analyzer for resolving unresolved attributes and relations.

Definition Classes
SnappyAQPSessionState → SnappySessionState → SessionState
final def asInstanceOf[T0]: T0

Definition Classes
Any
def beforeExecutePlan(plan: LogicalPlan): Unit

Attributes
protected
Definition Classes
SnappySessionState
lazy val catalog: SnappyAQPSessionCatalog

Internal catalog for managing table and database states.
Internal catalog for managing table and database states.

Definition Classes
SnappyAQPSessionState → SnappySessionState → SessionState
def clone(): AnyRef

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( ... )
lazy val conf: SnappyConf

SQL-specific key-value configurations.
SQL-specific key-value configurations.

Definition Classes
SnappySessionState → SessionState
val contextFunctions: SnappyContextAQPFunctions

Definition Classes
SnappyAQPSessionState → SnappySessionState
final def eq(arg0: AnyRef): Boolean

Definition Classes
AnyRef
def equals(arg0: Any): Boolean

Definition Classes
AnyRef → Any
final def executePlan(plan: LogicalPlan): QueryExecution

Definition Classes
SnappySessionState → SessionState
final lazy val executionCache: ConcurrentHashMap[LogicalPlan, QueryExecution]

Attributes
protected
Definition Classes
SnappySessionState
lazy val experimentalMethods: ExperimentalMethods

Definition Classes
SessionState
def finalize(): Unit

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( classOf[java.lang.Throwable] )
lazy val functionRegistry: FunctionRegistry

Internal catalog for managing functions registered by the user.
Internal catalog for managing functions registered by the user.

Definition Classes
SessionState
lazy val functionResourceLoader: FunctionResourceLoader

A class for loading resources specified by a function.
A class for loading resources specified by a function.

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

Definition Classes
AnyRef → Any
def getExtendedCheckRules: Seq[(LogicalPlan) ⇒ Unit]

Definition Classes
SnappySessionState
def getExtendedResolutionRules(analyzer: Analyzer): Seq[Rule[LogicalPlan]]

Definition Classes
SnappySessionState
def getTablePartitions(region: CacheDistributionAdvisee): Array[Partition]

Definition Classes
SnappySessionState
def getTablePartitions(region: PartitionedRegion): Array[Partition]

Definition Classes
SnappySessionState
def hashCode(): Int

Definition Classes
AnyRef → Any
val isAQPDebug: Boolean
val isDebugFixedSeed: Boolean
def isDisabled: Boolean

Definition Classes
SnappyStrategies
final def isInstanceOf[T0]: Boolean

Definition Classes
Any
var jdbcQueryJobGroupId: Option[String]

Definition Classes
SnappySessionState
lazy val listenerManager: ExecutionListenerManager

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
final def ne(arg0: AnyRef): Boolean

Definition Classes
AnyRef
def newHadoopConf(): Configuration

Definition Classes
SessionState
def newHadoopConfWithOptions(options: Map[String, String]): Configuration

Definition Classes
SessionState
def newQueryExecution(plan: LogicalPlan): QueryExecution

Attributes
protected
Definition Classes
SnappySessionState
final def notify(): Unit

Definition Classes
AnyRef
final def notifyAll(): Unit

Definition Classes
AnyRef
lazy val optimizer: Optimizer

Logical query plan optimizer.
Logical query plan optimizer.

Definition Classes
SnappySessionState → SessionState
def planner: SparkPlanner

Planner that converts optimized logical plans to physical plans.
Planner that converts optimized logical plans to physical plans.

Definition Classes
SessionState
def queryPreparations(topLevel: Boolean): Seq[Rule[SparkPlan]]

Attributes
protected[org.apache.spark.sql]
Definition Classes
SnappyAQPSessionState → SnappySessionState
def refreshTable(tableName: String): Unit

Definition Classes
SessionState
def registerStreamingQueryListener(streamingQueryListener: StreamingQueryListener): Unit

Definition Classes
SessionState
def removeStreamingQueryListener(): Unit

Definition Classes
SessionState
val sampleSnappyCase: PartialFunction[LogicalPlan, Seq[SparkPlan]]

Definition Classes
SnappyAQPSessionState → SnappySessionState
val snappySession: SnappySession

Definition Classes
SnappySessionState
lazy val sqlParser: SnappySqlParser

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

Definition Classes
SnappySessionState → SessionState
lazy val streamingQueryManager: StreamingQueryManager

Interface to start and stop StreamingQuerys.
Interface to start and stop StreamingQuerys.

Definition Classes
SnappySessionState → SessionState
final def synchronized[T0](arg0: ⇒ T0): T0

Definition Classes
AnyRef
def toString(): String

Definition Classes
AnyRef → Any
lazy val udf: UDFRegistration

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
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( ... )
lazy val wrapperCatalog: SessionCatalogWrapper

Attributes
protected
Definition Classes
SnappySessionState

Related Doc: package internal

final class SnappyAQPSessionState extends SnappySessionState

Instance Constructors

new SnappyAQPSessionState(_snappySession: SnappySession)

Type Members

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

final class LinkPartitionsToBuckets extends Rule[LogicalPlan]

Value Members

final def !=(arg0: Any): Boolean

final def ##(): Int

final def ==(arg0: Any): Boolean

object ExternalRelationLimitFetch extends Rule[LogicalPlan]

object HashJoinStrategies extends Strategy with JoinQueryPlanning

object OrderJoinConditions extends Rule[LogicalPlan] with JoinQueryPlanning

object PushDownWindowLogicalPlan extends Rule[LogicalPlan]

object ResolveAliasInGroupBy extends Rule[LogicalPlan]

object RowLevelSecurity extends Rule[LogicalPlan]

object SnappyAggregation extends Strategy

object SnappyStrategies extends Strategy

object StreamQueryStrategy extends Strategy

object TokenizedLiteralFolding extends Rule[LogicalPlan]

def addJar(path: String): Unit

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

lazy val analyzer: Analyzer

final def asInstanceOf[T0]: T0

def beforeExecutePlan(plan: LogicalPlan): Unit

lazy val catalog: SnappyAQPSessionCatalog

def clone(): AnyRef

lazy val conf: SnappyConf

val contextFunctions: SnappyContextAQPFunctions

final def eq(arg0: AnyRef): Boolean

def equals(arg0: Any): Boolean

final def executePlan(plan: LogicalPlan): QueryExecution

final lazy val executionCache: ConcurrentHashMap[LogicalPlan, QueryExecution]

lazy val experimentalMethods: ExperimentalMethods

def finalize(): Unit

lazy val functionRegistry: FunctionRegistry

lazy val functionResourceLoader: FunctionResourceLoader

final def getClass(): Class[_]

def getExtendedCheckRules: Seq[(LogicalPlan) ⇒ Unit]

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

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

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

def hashCode(): Int

val isAQPDebug: Boolean

val isDebugFixedSeed: Boolean

def isDisabled: Boolean

final def isInstanceOf[T0]: Boolean

var jdbcQueryJobGroupId: Option[String]

lazy val listenerManager: ExecutionListenerManager

final def ne(arg0: AnyRef): Boolean

def newHadoopConf(): Configuration

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

def newQueryExecution(plan: LogicalPlan): QueryExecution

final def notify(): Unit

final def notifyAll(): Unit

lazy val optimizer: Optimizer

def planner: SparkPlanner

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

def refreshTable(tableName: String): Unit

def registerStreamingQueryListener(streamingQueryListener: StreamingQueryListener): Unit

def removeStreamingQueryListener(): Unit

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

val snappySession: SnappySession

lazy val sqlParser: SnappySqlParser

lazy val streamingQueryManager: StreamingQueryManager

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

def toString(): String

lazy val udf: UDFRegistration

final def wait(): Unit

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

final def wait(arg0: Long): Unit

lazy val wrapperCatalog: SessionCatalogWrapper

Inherited from SnappySessionState

Inherited from SnappyStrategies

Inherited from SessionState

Inherited from AnyRef

Inherited from Any

Ungrouped