DataSourceRDDPartition

DataSourceRDDPartition is a Spark Core Partition of DataSourceRDD and Spark Structured Streaming’s ContinuousDataSourceRDD RDDs.

DataSourceRDDPartition is created when:

  • DataSourceRDD and Spark Structured Streaming’s ContinuousDataSourceRDD are requested for partitions

  • DataSourceRDD and Spark Structured Streaming’s ContinuousDataSourceRDD are requested to compute a partition

  • DataSourceRDD and Spark Structured Streaming’s ContinuousDataSourceRDD are requested for preferred locations

DataSourceRDDPartition takes the following when created:

results matching ""

    No results matching ""