Package org.apache.iceberg.util

Class PropertyUtil

java.lang.Object

org.apache.iceberg.util.PropertyUtil

public class PropertyUtil
extends Object

Method Summary

Modifier and Type	Method	Description
static Map<String,String>	applySchemaChanges(Map<String,String> properties, List<String> deletedColumns, Map<String,String> renamedColumns, Set<String> columnProperties)
static Map<String,String>	filterProperties(Map<String,String> properties, Predicate<String> keyPredicate)	Filter the properties map by the provided key predicate.
static Map<String,String>	propertiesWithPrefix(Map<String,String> properties, String prefix)	Returns subset of provided map with keys matching the provided prefix.
static boolean	propertyAsBoolean(Map<String,String> properties, String property, boolean defaultValue)
static double	propertyAsDouble(Map<String,String> properties, String property, double defaultValue)
static int	propertyAsInt(Map<String,String> properties, String property, int defaultValue)
static long	propertyAsLong(Map<String,String> properties, String property, long defaultValue)
static Boolean	propertyAsNullableBoolean(Map<String,String> properties, String property)
static Integer	propertyAsNullableInt(Map<String,String> properties, String property)
static Long	propertyAsNullableLong(Map<String,String> properties, String property)
static String	propertyAsString(Map<String,String> properties, String property, String defaultValue)
static int	propertyTryAsInt(Map<String,String> properties, String property, int defaultValue)
static void	validateCommitProperties(Map<String,String> properties)	Validate the table commit related properties to have non-negative integer on table creation to prevent commit failure

Methods inherited from class java.lang.Object

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

Method Details

propertyAsBoolean

public static boolean propertyAsBoolean(Map<String,String> properties,
 String property,
 boolean defaultValue)

propertyAsNullableBoolean

public static Boolean propertyAsNullableBoolean(Map<String,String> properties,
 String property)

propertyAsDouble

public static double propertyAsDouble(Map<String,String> properties,
 String property,
 double defaultValue)

propertyTryAsInt

public static int propertyTryAsInt(Map<String,String> properties,
 String property,
 int defaultValue)

propertyAsInt

public static int propertyAsInt(Map<String,String> properties,
 String property,
 int defaultValue)

propertyAsNullableInt

public static Integer propertyAsNullableInt(Map<String,String> properties,
 String property)

propertyAsLong

public static long propertyAsLong(Map<String,String> properties,
 String property,
 long defaultValue)

propertyAsNullableLong

public static Long propertyAsNullableLong(Map<String,String> properties,
 String property)

propertyAsString

public static String propertyAsString(Map<String,String> properties,
 String property,
 String defaultValue)

validateCommitProperties

public static void validateCommitProperties(Map<String,String> properties)

Validate the table commit related properties to have non-negative integer on table creation to prevent commit failure

propertiesWithPrefix

public static Map<String,String> propertiesWithPrefix(Map<String,String> properties,
 String prefix)

Returns subset of provided map with keys matching the provided prefix. Matching is case-sensitive and the matching prefix is removed from the keys in returned map.

Parameters:

properties - input map

prefix - prefix to choose keys from input map

Returns:

subset of input map with keys starting with provided prefix and prefix trimmed out

filterProperties

public static Map<String,String> filterProperties(Map<String,String> properties,
 Predicate<String> keyPredicate)

Filter the properties map by the provided key predicate.

Parameters:

properties - input map

keyPredicate - predicate to choose keys from input map

Returns:

subset of input map with keys satisfying the predicate

applySchemaChanges

public static Map<String,String> applySchemaChanges(Map<String,String> properties,
 List<String> deletedColumns,
 Map<String,String> renamedColumns,
 Set<String> columnProperties)