Class VeniceRawPubsubInputScanBuilder

java.lang.Object
com.linkedin.venice.spark.input.pubsub.raw.VeniceRawPubsubInputScanBuilder
All Implemented Interfaces:
org.apache.spark.sql.connector.read.ScanBuilder

public class VeniceRawPubsubInputScanBuilder extends Object implements org.apache.spark.sql.connector.read.ScanBuilder
  • Constructor Details

    • VeniceRawPubsubInputScanBuilder

      public VeniceRawPubsubInputScanBuilder(VeniceProperties properties)
  • Method Details

    • build

      public org.apache.spark.sql.connector.read.Scan build()
      Specified by:
      build in interface org.apache.spark.sql.connector.read.ScanBuilder