Package com.linkedin.venice.spark.input.pubsub.raw

Class VeniceRawPubsubInputTable

java.lang.Object

com.linkedin.venice.spark.input.pubsub.raw.VeniceRawPubsubInputTable

All Implemented Interfaces:

org.apache.spark.sql.connector.catalog.SupportsRead, org.apache.spark.sql.connector.catalog.Table

public class VeniceRawPubsubInputTable
extends Object
implements org.apache.spark.sql.connector.catalog.SupportsRead

Constructor Summary

Constructors

Constructor	Description
VeniceRawPubsubInputTable(VeniceProperties jobConfig)

Method Summary

Modifier and Type	Method	Description
Set<org.apache.spark.sql.connector.catalog.TableCapability>	capabilities()
String	name()
org.apache.spark.sql.connector.read.ScanBuilder	newScanBuilder(org.apache.spark.sql.util.CaseInsensitiveStringMap options)
org.apache.spark.sql.types.StructType	schema()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.spark.sql.connector.catalog.Table

partitioning, properties

Constructor Details

VeniceRawPubsubInputTable

public VeniceRawPubsubInputTable(VeniceProperties jobConfig)

Method Details

newScanBuilder

public org.apache.spark.sql.connector.read.ScanBuilder newScanBuilder(org.apache.spark.sql.util.CaseInsensitiveStringMap options)

Specified by:

newScanBuilder in interface org.apache.spark.sql.connector.catalog.SupportsRead

name

public String name()

Specified by:

name in interface org.apache.spark.sql.connector.catalog.Table

schema

public org.apache.spark.sql.types.StructType schema()

Specified by:

schema in interface org.apache.spark.sql.connector.catalog.Table

capabilities

public Set<org.apache.spark.sql.connector.catalog.TableCapability> capabilities()

Specified by:

capabilities in interface org.apache.spark.sql.connector.catalog.Table