Class Hierarchy
- java.lang.Object
- com.linkedin.venice.spark.input.pubsub.raw.VeniceBasicPubsubInputPartition (implements org.apache.spark.sql.connector.read.InputPartition)
- com.linkedin.venice.spark.input.pubsub.raw.VeniceRawPubsubInputPartitionReader (implements org.apache.spark.sql.connector.read.PartitionReader<T>)
- com.linkedin.venice.spark.input.pubsub.raw.VeniceRawPubsubInputPartitionReaderFactory (implements org.apache.spark.sql.connector.read.PartitionReaderFactory)
- com.linkedin.venice.spark.input.pubsub.raw.VeniceRawPubsubInputScan (implements org.apache.spark.sql.connector.read.Batch, org.apache.spark.sql.connector.read.Scan)
- com.linkedin.venice.spark.input.pubsub.raw.VeniceRawPubsubInputScanBuilder (implements org.apache.spark.sql.connector.read.ScanBuilder)
- com.linkedin.venice.spark.input.pubsub.raw.VeniceRawPubsubInputTable (implements org.apache.spark.sql.connector.catalog.SupportsRead)
- com.linkedin.venice.spark.input.pubsub.raw.VeniceRawPubsubSource (implements org.apache.spark.sql.connector.catalog.TableProvider)
- com.linkedin.venice.spark.input.pubsub.raw.VeniceRawPubsubStats