Package org.apache.iceberg.flink.maintenance.operator

Class FileUriKeySelector

java.lang.Object

org.apache.iceberg.flink.maintenance.operator.FileUriKeySelector

All Implemented Interfaces:

Serializable, org.apache.flink.api.common.functions.Function, org.apache.flink.api.java.functions.KeySelector<String,String>

@Internal
public class FileUriKeySelector
extends Object
implements org.apache.flink.api.java.functions.KeySelector<String,String>

A key selector implementation that extracts a normalized file path from a file URI string.

This selector groups file URIs by their normalized path, ignoring differences in scheme and authority that are considered equivalent according to the provided mappings.

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
FileUriKeySelector(Map<String,String> equalSchemes, Map<String,String> equalAuthorities)

Method Summary

Modifier and Type	Method	Description
String	getKey(String value)

Methods inherited from class java.lang.Object

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

Constructor Details

FileUriKeySelector

public FileUriKeySelector(Map<String,String> equalSchemes,
 Map<String,String> equalAuthorities)

Method Details

getKey

public String getKey(String value)
              throws Exception

Specified by:

getKey in interface org.apache.flink.api.java.functions.KeySelector<String,String>

Throws:

Exception