StateStoreAwareZipPartitionsHelper¶

StateStoreAwareZipPartitionsHelper is a Scala implicit class of a data RDD (of type RDD[T]) to create a StateStoreAwareZipPartitionsRDD for StreamingSymmetricHashJoinExec physical operator.

Creating StateStoreAwareZipPartitionsRDD¶

stateStoreAwareZipPartitions[U: ClassTag, V: ClassTag](
  dataRDD2: RDD[U],
  stateInfo: StatefulOperatorStateInfo,
  storeNames: Seq[String],
  storeCoordinator: StateStoreCoordinatorRef)(
  f: (Iterator[T], Iterator[U]) => Iterator[V]): RDD[V]

stateStoreAwareZipPartitions simply creates a new StateStoreAwareZipPartitionsRDD.

stateStoreAwareZipPartitions is used when StreamingSymmetricHashJoinExec physical operator is executed.