Class PslTableProvider (1.0.0)

public class PslTableProvider implements TableProvider, DataSourceRegister

Inheritance

java.lang.Object > PslTableProvider

Implements

org.apache.spark.sql.connector.catalog.TableProvider, org.apache.spark.sql.sources.DataSourceRegister

Constructors

PslTableProvider()

public PslTableProvider()

Methods

getTable(StructType structType, Transform[] transforms, Map<String,String> map)

public Table getTable(StructType structType, Transform[] transforms, Map<String,String> map)
Parameters
NameDescription
structTypeorg.apache.spark.sql.types.StructType
transformsorg.apache.spark.sql.connector.expressions.Transform[]
mapMap<String,String>
Returns
TypeDescription
org.apache.spark.sql.connector.catalog.Table

inferSchema(CaseInsensitiveStringMap caseInsensitiveStringMap)

public StructType inferSchema(CaseInsensitiveStringMap caseInsensitiveStringMap)
Parameter
NameDescription
caseInsensitiveStringMaporg.apache.spark.sql.util.CaseInsensitiveStringMap
Returns
TypeDescription
org.apache.spark.sql.types.StructType

shortName()

public String shortName()
Returns
TypeDescription
String