IcebergPageSourceProvider

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total2,307 of 2,3070%150 of 1500%1181184594594242
createParquetPageSource(HdfsEnvironment, ConnectorSession, Configuration, Path, long, long, List, TupleDomain, FileFormatDataSourceStats, ParquetMetadataSource)4420%300%1616989811
createBatchOrcPageSource(HdfsEnvironment, String, Configuration, Path, long, long, boolean, List, TypeManager, TupleDomain, OrcReaderOptions, OrcEncoding, DataSize, DataSize, boolean, boolean, int, OrcFileTailSource, StripeMetadataSourceFactory, FileFormatDataSourceStats, Optional, DwrfEncryptionProvider)3630%180%1010828211
createPageSource(ConnectorTransactionHandle, ConnectorSession, ConnectorSplit, ConnectorTableLayoutHandle, List, SplitContext, RuntimeStats)2990%140%88595911
readDeletes(ConnectorSession, Schema, String, List, Optional, Optional, boolean)2840%300%1616494911
getFileOrcColumns(OrcReader)1320%80%55282811
createDataPageSource(ConnectorSession, HdfsContext, Path, long, long, FileFormat, List, TupleDomain, boolean)930%30%33191911
IcebergPageSourceProvider(HdfsEnvironment, FileFormatDataSourceStats, TypeManager, OrcFileTailSource, StripeMetadataSourceFactory, HiveDwrfEncryptionProvider, HiveClientConfig, ParquetMetadataSource, IcebergFileWriterFactory, JsonCodec, PageIndexerFactory, IcebergConfig, SortParameters)840%n/a11161611
lambda$createBatchOrcPageSource$13(Map, Map, IcebergColumnHandle)540%80%55131311
lambda$null$17(Set, Schema, ColumnIdentity)510%40%33101011
requiredColumnsForDeletes(Schema, PartitionSpec, List, boolean)490%80%559911
lambda$getFileOrcColumns$15(OrcType, List, int)320%n/a115511
lambda$getParquetTupleDomain$6(Map, ImmutableMap.Builder, IcebergColumnHandle, Domain)320%80%556611
getColumnType(Map, MessageType, IcebergColumnHandle)290%40%336611
lambda$createPageSource$26(Table, LocationProvider, HdfsContext, Schema, PartitionSpec, ConnectorSession, IcebergSplit, IcebergTableHandle)290%n/a114411
lambda$getFileOrcColumns$14(OrcType, List, int)270%n/a116611
lambda$createPageSource$22(IcebergSplit, boolean, ConnectorSession, Schema, IcebergPartitionInsertingPageSource, boolean)250%n/a119911
getHiveColumnHandleColumnType(BaseHiveColumnHandle.ColumnType)220%30%334411
openDeletes(ConnectorSession, DeleteFile, List, TupleDomain)220%n/a115511
lambda$createPageSource$20(Schema, IcebergSplit, LocationProvider, HdfsContext, ConnectorSession)220%n/a115511
lambda$createPageSource$19(ConnectorSession, HdfsContext, IcebergSplit, IcebergTableLayoutHandle, SplitContext, List)210%n/a117711
lambda$createPageSource$18(Set, Schema, IcebergColumnHandle)210%n/a118811
getParquetTupleDomain(Map, TupleDomain)190%20%225511
lambda$createBatchOrcPageSource$10(IcebergOrcColumn)120%n/a111111
lambda$createParquetPageSource$4(MessageType, Type)120%n/a111111
lambda$createParquetPageSource$0(ParquetMetadataSource, ParquetDataSource, long, HiveFileContext, Optional, boolean)120%n/a114411
lambda$createPageSource$24(Supplier, List)100%n/a113311
lambda$null$21(boolean, DeleteFile)100%40%331111
lambda$null$16(Set, ColumnIdentity)100%20%221111
lambda$createBatchOrcPageSource$12(ImmutableMap.Builder, IcebergColumnHandle, Domain)100%20%223311
lambda$readDeletes$29(Schema, Integer)90%n/a111111
lambda$createBatchOrcPageSource$9(IcebergOrcColumn)80%n/a111111
lambda$readDeletes$28(byte[])70%n/a111111
lambda$readDeletes$27(byte[])70%n/a111111
lambda$createParquetPageSource$5(MessageType)70%n/a111111
lambda$createParquetPageSource$1(Type)70%20%221111
lambda$createPageSource$25()50%n/a111111
lambda$createBatchOrcPageSource$11(IcebergOrcColumn)50%n/a111111
lambda$createBatchOrcPageSource$8(IcebergOrcColumn)50%n/a111111
lambda$createBatchOrcPageSource$7(ExtendedFileSystem, Path, HiveFileContext)50%n/a111111
lambda$createParquetPageSource$3(Map, MessageType, IcebergColumnHandle)50%n/a111111
lambda$createParquetPageSource$2(Type)50%n/a111111
lambda$null$23(List, DeleteFilter)40%n/a111111