Package org.apache.polaris.service.catalog.io

Class MeasuredFileIOFactory

java.lang.Object

org.apache.polaris.service.catalog.io.MeasuredFileIOFactory

All Implemented Interfaces:

org.apache.polaris.service.catalog.io.FileIOFactory

@Vetoed
public class MeasuredFileIOFactory
extends Object
implements org.apache.polaris.service.catalog.io.FileIOFactory

A FileIOFactory that measures the number of bytes read, files written, and files deleted. It can inject exceptions at various parts of the IO construction.

Field Summary

Fields

Modifier and Type	Field	Description
Optional<Supplier<RuntimeException>>	getLengthExceptionSupplier
Optional<Supplier<RuntimeException>>	loadFileIOExceptionSupplier
Optional<Supplier<RuntimeException>>	newInputFileExceptionSupplier
Optional<Supplier<RuntimeException>>	newOutputFileExceptionSupplier

Constructor Summary

Constructors

Constructor	Description
MeasuredFileIOFactory()

Method Summary

Modifier and Type	Method	Description
long	getInputBytes()
long	getNumDeletedFiles()
long	getNumOutputFiles()
org.apache.iceberg.io.FileIO	loadFileIO(org.apache.polaris.core.storage.StorageAccessConfig storageAccessConfig, String ioImplClassName, Map<String,String> properties)

Methods inherited from class java.lang.Object

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

Field Details

loadFileIOExceptionSupplier

public Optional<Supplier<RuntimeException>> loadFileIOExceptionSupplier

newInputFileExceptionSupplier

public Optional<Supplier<RuntimeException>> newInputFileExceptionSupplier

newOutputFileExceptionSupplier

public Optional<Supplier<RuntimeException>> newOutputFileExceptionSupplier

getLengthExceptionSupplier

public Optional<Supplier<RuntimeException>> getLengthExceptionSupplier

Constructor Details

MeasuredFileIOFactory

@Inject
public MeasuredFileIOFactory()

Method Details

loadFileIO

public org.apache.iceberg.io.FileIO loadFileIO(@Nonnull
 org.apache.polaris.core.storage.StorageAccessConfig storageAccessConfig,
 @Nonnull
 String ioImplClassName,
 @Nonnull
 Map<String,String> properties)

Specified by:

loadFileIO in interface org.apache.polaris.service.catalog.io.FileIOFactory

getInputBytes

public long getInputBytes()

getNumOutputFiles

public long getNumOutputFiles()

getNumDeletedFiles

public long getNumDeletedFiles()