sequenceDiagram
    participant PrestoScheduler
    participant DeltaSplitManager
    participant DeltaKernelReader
    participant AddFileStatus
    participant HiveSplitCreator

    PrestoScheduler->>DeltaSplitManager: getNextBatch(partitionHandle, tableHandle, splitSchedulingContext)
    DeltaSplitManager->>DeltaKernelReader: listFilesForScan(tableHandle)
    DeltaKernelReader-->>DeltaSplitManager: AddFileStatus rows

    loop For each AddFileStatus
        DeltaSplitManager->>AddFileStatus: getPath()
        AddFileStatus-->>DeltaSplitManager: filePath
        Note right of DeltaSplitManager: filePath is now used directly
        DeltaSplitManager->>HiveSplitCreator: createSplit(filePath, startOffset, length)
        HiveSplitCreator-->>DeltaSplitManager: ConnectorSplit
    end

    DeltaSplitManager-->>PrestoScheduler: ConnectorSplitBatch

sequenceDiagram
    participant Planner
    participant DeltaExpressionUtils
    participant InternalScanFileUtils
    participant Row
    participant AddFileStatus

    Planner->>DeltaExpressionUtils: evaluatePartitionPredicate(predicate, partitionColumns, row)

    loop For each partitionColumn
        DeltaExpressionUtils->>InternalScanFileUtils: getPartitionValues(row)
        InternalScanFileUtils-->>DeltaExpressionUtils: partitionValues
        DeltaExpressionUtils->>partitionValues: get(columnName)
        partitionValues-->>DeltaExpressionUtils: partitionValue

        DeltaExpressionUtils->>InternalScanFileUtils: getAddFileStatus(row)
        InternalScanFileUtils-->>DeltaExpressionUtils: AddFileStatus
        DeltaExpressionUtils->>AddFileStatus: getPath()
        AddFileStatus-->>DeltaExpressionUtils: filePath
        Note right of DeltaExpressionUtils: filePath is used directly without URI.create

        DeltaExpressionUtils->>DeltaExpressionUtils: getDomain(partitionColumn, partitionValue, typeManager, filePath)
    end

    DeltaExpressionUtils-->>Planner: boolean result

classDiagram
    class DeltaSplitManager {
        +CompletableFuture getNextBatch(ConnectorPartitionHandle partitionHandle, ConnectorTableHandle tableHandle, SplitSchedulingContext splitSchedulingContext)
    }

    class DeltaExpressionUtils {
        -static boolean evaluatePartitionPredicate(ConnectorSession session, TupleDomain partitionPredicate, List partitionColumns, Object row, TypeManager typeManager)
        -static Domain getDomain(DeltaColumnHandle partitionColumn, String partitionValue, TypeManager typeManager, String filePath)
    }

    class InternalScanFileUtils {
        +Map getPartitionValues(Object row)
        +AddFileStatus getAddFileStatus(Object row)
    }

    class AddFileStatus {
        +String getPath()
        +long getSize()
    }

    class ConnectorSplitBatch
    class ConnectorPartitionHandle
    class ConnectorTableHandle
    class SplitSchedulingContext
    class Domain
    class DeltaColumnHandle {
        +String getName()
    }
    class TypeManager

    DeltaSplitManager --> AddFileStatus : uses
    DeltaSplitManager --> ConnectorSplitBatch : returns
    DeltaSplitManager --> ConnectorPartitionHandle : parameter
    DeltaSplitManager --> ConnectorTableHandle : parameter
    DeltaSplitManager --> SplitSchedulingContext : parameter

    DeltaExpressionUtils --> InternalScanFileUtils : uses
    DeltaExpressionUtils --> AddFileStatus : uses
    DeltaExpressionUtils --> Domain : creates
    DeltaExpressionUtils --> DeltaColumnHandle : uses
    DeltaExpressionUtils --> TypeManager : uses
    InternalScanFileUtils --> AddFileStatus : returns