org.apache.nifi.processors.iceberg.catalog

Class IcebergCatalogFactory

java.lang.Object

org.apache.nifi.processors.iceberg.catalog.IcebergCatalogFactory

public class IcebergCatalogFactory
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
private IcebergCatalogService	catalogService

Constructor Summary

Constructors

Constructor and Description
IcebergCatalogFactory(IcebergCatalogService catalogService)

Method Summary

Modifier and Type	Method and Description
org.apache.iceberg.catalog.Catalog	create()
private org.apache.iceberg.catalog.Catalog	initHadoopCatalog(IcebergCatalogService catalogService)
private org.apache.iceberg.catalog.Catalog	initHiveCatalog(IcebergCatalogService catalogService)

Methods inherited from class java.lang.Object

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

Field Detail

catalogService

private final IcebergCatalogService catalogService

Constructor Detail

IcebergCatalogFactory

public IcebergCatalogFactory(IcebergCatalogService catalogService)

Method Detail

create

public org.apache.iceberg.catalog.Catalog create()

initHiveCatalog

private org.apache.iceberg.catalog.Catalog initHiveCatalog(IcebergCatalogService catalogService)

initHadoopCatalog

private org.apache.iceberg.catalog.Catalog initHadoopCatalog(IcebergCatalogService catalogService)