org.apache.nifi.processors.iceberg

Class IcebergUtils

java.lang.Object

org.apache.nifi.processors.iceberg.IcebergUtils

public class IcebergUtils
extends Object

Constructor Summary

Constructors

Constructor and Description
IcebergUtils()

Method Summary

Modifier and Type	Method and Description
static <T extends Throwable> Optional<T>	findCause(Throwable t, Class<T> expectedCauseType, Predicate<T> causePredicate) Returns an optional with the first throwable in the causal chain that is assignable to the provided cause type, and satisfies the provided cause predicate, Optional.empty() otherwise.
static org.apache.hadoop.conf.Configuration	getConfigurationFromFiles(List<String> configFilePaths) Loads configuration files from the provided paths.
static Map<String,String>	getDynamicProperties(ProcessContext context, FlowFile flowFile) Collects every non-blank dynamic property from the context.

Methods inherited from class java.lang.Object

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

Constructor Detail

IcebergUtils

public IcebergUtils()

Method Detail

getConfigurationFromFiles

public static org.apache.hadoop.conf.Configuration getConfigurationFromFiles(List<String> configFilePaths)

Loads configuration files from the provided paths.

Parameters:

configFilePaths - list of config file paths separated with comma

Returns:

merged configuration

getDynamicProperties

public static Map<String,String> getDynamicProperties(ProcessContext context,
                                                      FlowFile flowFile)

Collects every non-blank dynamic property from the context.

Parameters:

context - process context

flowFile - FlowFile to evaluate attribute expressions

Returns:

Map of dynamic properties

findCause

public static <T extends Throwable> Optional<T> findCause(Throwable t,
                                                          Class<T> expectedCauseType,
                                                          Predicate<T> causePredicate)

Returns an optional with the first throwable in the causal chain that is assignable to the provided cause type, and satisfies the provided cause predicate, Optional.empty() otherwise.

Parameters:

t - The throwable to inspect for the cause.

Returns:

Throwable Cause