org.apache.paimon.spark.utils

Class CatalogUtils

java.lang.Object

org.apache.paimon.spark.utils.CatalogUtils

public class CatalogUtils
extends Object

Utils of catalog.

Constructor Summary

Constructors

Constructor and Description
CatalogUtils()

Method Summary

Modifier and Type	Method and Description
static void	checkNamespace(String[] namespace)
static Object	convertSparkJavaToPaimonJava(org.apache.spark.sql.types.DataType sparkType, Object value)
static String	paimonType2JavaType(DataType type)
static org.apache.spark.sql.types.DataType	paimonType2SparkType(DataType type)
static org.apache.spark.sql.connector.catalog.Identifier	removeCatalogName(org.apache.spark.sql.connector.catalog.Identifier ident, String catalogName)
static Identifier	toIdentifier(org.apache.spark.sql.connector.catalog.Identifier ident)

Methods inherited from class java.lang.Object

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

Constructor Detail

CatalogUtils

public CatalogUtils()

Method Detail

checkNamespace

public static void checkNamespace(String[] namespace)

toIdentifier

public static Identifier toIdentifier(org.apache.spark.sql.connector.catalog.Identifier ident)

removeCatalogName

public static org.apache.spark.sql.connector.catalog.Identifier removeCatalogName(org.apache.spark.sql.connector.catalog.Identifier ident,
                                                                                  String catalogName)

paimonType2SparkType

public static org.apache.spark.sql.types.DataType paimonType2SparkType(DataType type)

paimonType2JavaType

public static String paimonType2JavaType(DataType type)

convertSparkJavaToPaimonJava

public static Object convertSparkJavaToPaimonJava(org.apache.spark.sql.types.DataType sparkType,
                                                  Object value)