package execution
Ordering
- Alphabetic
Visibility
- Public
- All
Type Members
-
case class
CassandraDirectJoinExec(leftKeys: Seq[Expression], rightKeys: Seq[Expression], joinType: JoinType, cassandraSide: BuildSide, condition: Option[Expression], child: SparkPlan, aliasMap: Map[String, ExprId], cassandraPlan: BatchScanExec) extends SparkPlan with UnaryExecNode with Product with Serializable
A physical plan for performing a join against a CassandraTable given a set of keys.
-
case class
CassandraDirectJoinStrategy(spark: SparkSession) extends Strategy with Serializable with Product
Direct Join Strategy Converts logical plans where the join target is a Cassandra derived branch with joinWithCassandraTable style Join
Value Members
- object CassandraDirectJoinStrategy extends Logging with Serializable