org.apache.beam.sdk.io.iceberg

Class IcebergCatalogConfig.Builder

java.lang.Object

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

Enclosing class:

IcebergCatalogConfig

public abstract static class IcebergCatalogConfig.Builder
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
Builder()

Method Summary

Modifier and Type	Method and Description
abstract IcebergCatalogConfig	build()
abstract IcebergCatalogConfig.Builder	setAppIdentifier(java.lang.String id)
abstract IcebergCatalogConfig.Builder	setAuthSessionTimeoutMillis(long timeout)
abstract IcebergCatalogConfig.Builder	setCacheCaseSensitive(boolean cacheCaseSensitive)
abstract IcebergCatalogConfig.Builder	setCacheEnabled(boolean cacheEnabled)
abstract IcebergCatalogConfig.Builder	setCacheExpirationIntervalMillis(long expiration)
abstract IcebergCatalogConfig.Builder	setCatalogImplementation(java.lang.String catalogImpl)
abstract IcebergCatalogConfig.Builder	setClientPoolCacheKeys(java.lang.String keys)
abstract IcebergCatalogConfig.Builder	setClientPoolEvictionIntervalMs(long interval)
abstract IcebergCatalogConfig.Builder	setClientPoolSize(int size)
abstract IcebergCatalogConfig.Builder	setConfiguration(Configuration conf)
abstract IcebergCatalogConfig.Builder	setFileIOImplementation(java.lang.String fileIOImpl)
abstract IcebergCatalogConfig.Builder	setIcebergCatalogType(java.lang.String icebergType)
abstract IcebergCatalogConfig.Builder	setIOManifestCacheEnabled(boolean enabled)
abstract IcebergCatalogConfig.Builder	setIOManifestCacheExpirationIntervalMillis(long expiration)
abstract IcebergCatalogConfig.Builder	setIOManifestCacheMaxContentLength(long length)
abstract IcebergCatalogConfig.Builder	setIOManifestCacheMaxTotalBytes(long bytes)
abstract IcebergCatalogConfig.Builder	setLockAcquireIntervalMillis(long interval)
abstract IcebergCatalogConfig.Builder	setLockAcquireTimeoutMillis(long timeout)
abstract IcebergCatalogConfig.Builder	setLockHeartbeatIntervalMillis(long interval)
abstract IcebergCatalogConfig.Builder	setLockHeartbeatThreads(int threads)
abstract IcebergCatalogConfig.Builder	setLockHeartbeatTimeoutMillis(long timeout)
abstract IcebergCatalogConfig.Builder	setLockImplementation(java.lang.String lockImplementation)
abstract IcebergCatalogConfig.Builder	setMetricsReporterImplementation(java.lang.String metricsImpl)
abstract IcebergCatalogConfig.Builder	setName(java.lang.String name)
abstract IcebergCatalogConfig.Builder	setUri(java.lang.String uri)
abstract IcebergCatalogConfig.Builder	setUser(java.lang.String user)
abstract IcebergCatalogConfig.Builder	setWarehouseLocation(java.lang.String warehouse)

Methods inherited from class java.lang.Object

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

Constructor Detail

Builder

public Builder()

Method Detail

setName

public abstract IcebergCatalogConfig.Builder setName(java.lang.String name)

setIcebergCatalogType

public abstract IcebergCatalogConfig.Builder setIcebergCatalogType(@Nullable
                                                                   java.lang.String icebergType)

setCatalogImplementation

public abstract IcebergCatalogConfig.Builder setCatalogImplementation(@Nullable
                                                                      java.lang.String catalogImpl)

setFileIOImplementation

public abstract IcebergCatalogConfig.Builder setFileIOImplementation(@Nullable
                                                                     java.lang.String fileIOImpl)

setWarehouseLocation

public abstract IcebergCatalogConfig.Builder setWarehouseLocation(@Nullable
                                                                  java.lang.String warehouse)

setMetricsReporterImplementation

public abstract IcebergCatalogConfig.Builder setMetricsReporterImplementation(@Nullable
                                                                              java.lang.String metricsImpl)

setCacheEnabled

public abstract IcebergCatalogConfig.Builder setCacheEnabled(boolean cacheEnabled)

setCacheCaseSensitive

public abstract IcebergCatalogConfig.Builder setCacheCaseSensitive(boolean cacheCaseSensitive)

setCacheExpirationIntervalMillis

public abstract IcebergCatalogConfig.Builder setCacheExpirationIntervalMillis(long expiration)

setIOManifestCacheEnabled

public abstract IcebergCatalogConfig.Builder setIOManifestCacheEnabled(boolean enabled)

setIOManifestCacheExpirationIntervalMillis

public abstract IcebergCatalogConfig.Builder setIOManifestCacheExpirationIntervalMillis(long expiration)

setIOManifestCacheMaxTotalBytes

public abstract IcebergCatalogConfig.Builder setIOManifestCacheMaxTotalBytes(long bytes)

setIOManifestCacheMaxContentLength

public abstract IcebergCatalogConfig.Builder setIOManifestCacheMaxContentLength(long length)

setUri

public abstract IcebergCatalogConfig.Builder setUri(@Nullable
                                                    java.lang.String uri)

setClientPoolSize

public abstract IcebergCatalogConfig.Builder setClientPoolSize(int size)

setClientPoolEvictionIntervalMs

public abstract IcebergCatalogConfig.Builder setClientPoolEvictionIntervalMs(long interval)

setClientPoolCacheKeys

public abstract IcebergCatalogConfig.Builder setClientPoolCacheKeys(@Nullable
                                                                    java.lang.String keys)

setLockImplementation

public abstract IcebergCatalogConfig.Builder setLockImplementation(@Nullable
                                                                   java.lang.String lockImplementation)

setLockHeartbeatIntervalMillis

public abstract IcebergCatalogConfig.Builder setLockHeartbeatIntervalMillis(long interval)

setLockHeartbeatTimeoutMillis

public abstract IcebergCatalogConfig.Builder setLockHeartbeatTimeoutMillis(long timeout)

setLockHeartbeatThreads

public abstract IcebergCatalogConfig.Builder setLockHeartbeatThreads(int threads)

setLockAcquireIntervalMillis

public abstract IcebergCatalogConfig.Builder setLockAcquireIntervalMillis(long interval)

setLockAcquireTimeoutMillis

public abstract IcebergCatalogConfig.Builder setLockAcquireTimeoutMillis(long timeout)

setAppIdentifier

public abstract IcebergCatalogConfig.Builder setAppIdentifier(@Nullable
                                                              java.lang.String id)

setUser

public abstract IcebergCatalogConfig.Builder setUser(@Nullable
                                                     java.lang.String user)

setAuthSessionTimeoutMillis

public abstract IcebergCatalogConfig.Builder setAuthSessionTimeoutMillis(long timeout)

setConfiguration

public abstract IcebergCatalogConfig.Builder setConfiguration(@Nullable
                                                              Configuration conf)

build

public abstract IcebergCatalogConfig build()