org.apache.beam.sdk.io.iceberg

Class IcebergCatalogConfig

java.lang.Object

org.apache.beam.sdk.io.iceberg.IcebergCatalogConfig

All Implemented Interfaces:

java.io.Serializable

public abstract class IcebergCatalogConfig
extends java.lang.Object
implements java.io.Serializable

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	IcebergCatalogConfig.Builder

Constructor Summary

Constructors

Constructor and Description
IcebergCatalogConfig()

Method Summary

Modifier and Type	Method and Description
static IcebergCatalogConfig.Builder	builder()
org.apache.iceberg.catalog.Catalog	catalog()
abstract java.lang.String	getAppIdentifier()
abstract long	getAuthSessionTimeoutMillis()
abstract boolean	getCacheCaseSensitive()
abstract boolean	getCacheEnabled()
abstract long	getCacheExpirationIntervalMillis()
abstract java.lang.String	getCatalogImplementation()
abstract java.lang.String	getClientPoolCacheKeys()
abstract long	getClientPoolEvictionIntervalMs()
abstract int	getClientPoolSize()
abstract Configuration	getConfiguration()
abstract java.lang.String	getFileIOImplementation()
abstract java.lang.String	getIcebergCatalogType()
abstract boolean	getIOManifestCacheEnabled()
abstract long	getIOManifestCacheExpirationIntervalMillis()
abstract long	getIOManifestCacheMaxContentLength()
abstract long	getIOManifestCacheMaxTotalBytes()
abstract long	getLockAcquireIntervalMillis()
abstract long	getLockAcquireTimeoutMillis()
abstract long	getLockHeartbeatIntervalMillis()
abstract int	getLockHeartbeatThreads()
abstract long	getLockHeartbeatTimeoutMillis()
abstract java.lang.String	getLockImplementation()
abstract java.lang.String	getMetricsReporterImplementation()
abstract java.lang.String	getName()
abstract java.lang.String	getUri()
abstract java.lang.String	getUser()
abstract java.lang.String	getWarehouseLocation()
org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.collect.ImmutableMap<java.lang.String,java.lang.String>	properties()

Methods inherited from class java.lang.Object

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

Constructor Detail

IcebergCatalogConfig

public IcebergCatalogConfig()

Method Detail

getName

@Pure
public abstract java.lang.String getName()

getIcebergCatalogType

@Pure
 @Nullable
public abstract java.lang.String getIcebergCatalogType()

getCatalogImplementation

@Pure
 @Nullable
public abstract java.lang.String getCatalogImplementation()

getFileIOImplementation

@Pure
 @Nullable
public abstract java.lang.String getFileIOImplementation()

getWarehouseLocation

@Pure
 @Nullable
public abstract java.lang.String getWarehouseLocation()

getMetricsReporterImplementation

@Pure
 @Nullable
public abstract java.lang.String getMetricsReporterImplementation()

getCacheEnabled

@Pure
public abstract boolean getCacheEnabled()

getCacheCaseSensitive

@Pure
public abstract boolean getCacheCaseSensitive()

getCacheExpirationIntervalMillis

@Pure
public abstract long getCacheExpirationIntervalMillis()

getIOManifestCacheEnabled

@Pure
public abstract boolean getIOManifestCacheEnabled()

getIOManifestCacheExpirationIntervalMillis

@Pure
public abstract long getIOManifestCacheExpirationIntervalMillis()

getIOManifestCacheMaxTotalBytes

@Pure
public abstract long getIOManifestCacheMaxTotalBytes()

getIOManifestCacheMaxContentLength

@Pure
public abstract long getIOManifestCacheMaxContentLength()

getUri

@Pure
 @Nullable
public abstract java.lang.String getUri()

getClientPoolSize

@Pure
public abstract int getClientPoolSize()

getClientPoolEvictionIntervalMs

@Pure
public abstract long getClientPoolEvictionIntervalMs()

getClientPoolCacheKeys

@Pure
 @Nullable
public abstract java.lang.String getClientPoolCacheKeys()

getLockImplementation

@Pure
 @Nullable
public abstract java.lang.String getLockImplementation()

getLockHeartbeatIntervalMillis

@Pure
public abstract long getLockHeartbeatIntervalMillis()

getLockHeartbeatTimeoutMillis

@Pure
public abstract long getLockHeartbeatTimeoutMillis()

getLockHeartbeatThreads

@Pure
public abstract int getLockHeartbeatThreads()

getLockAcquireIntervalMillis

@Pure
public abstract long getLockAcquireIntervalMillis()

getLockAcquireTimeoutMillis

@Pure
public abstract long getLockAcquireTimeoutMillis()

getAppIdentifier

@Pure
 @Nullable
public abstract java.lang.String getAppIdentifier()

getUser

@Pure
 @Nullable
public abstract java.lang.String getUser()

getAuthSessionTimeoutMillis

@Pure
public abstract long getAuthSessionTimeoutMillis()

getConfiguration

@Pure
 @Nullable
public abstract Configuration getConfiguration()

builder

@Pure
public static IcebergCatalogConfig.Builder builder()

properties

@Pure
public org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.collect.ImmutableMap<java.lang.String,java.lang.String> properties()

catalog

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