execution

Type Members

1. case class CassandraDirectJoinExec(leftKeys: Seq[Expression], rightKeys: Seq[Expression], joinType: JoinType, cassandraSide: BuildSide, condition: Option[Expression], child: SparkPlan, aliasMap: Map[String, ExprId], cassandraScan: CassandraTableScanRDD[_], cassandraPlan: DataSourceScanExec) extends SparkPlan with UnaryExecNode with Product with Serializable

   

   A physical plan for performing a join against a CassandraTable given a set of keys.

2. 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