Package io.deephaven.iceberg.internal

Class Explore

java.lang.Object
io.deephaven.iceberg.internal.Explore
@InternalUseOnly public final class Explore extends Object
These are undocumented methods, potentially useful for debugging various Iceberg table states. They are subject to change, or removal, at any time. 
 import jpy
 from deephaven.table import Table
 from deephaven.experimental.iceberg import IcebergTableAdapter

 _JExplore = jpy.get_type("io.deephaven.iceberg.internal.Explore")


 def snapshots(ita: IcebergTableAdapter) -> Table:
     return Table(_JExplore.snapshots(ita.j_object.icebergTable()))


 def manifest_files(ita: IcebergTableAdapter) -> Table:
     return Table(_JExplore.manifestFiles(ita.j_object.icebergTable()))


 def content_files(ita: IcebergTableAdapter) -> Table:
     return Table(_JExplore.contentFiles(ita.j_object.icebergTable()))


 def refs(ita: IcebergTableAdapter) -> Table:
     return Table(_JExplore.refs(ita.j_object.icebergTable()))


 def properties(ita: IcebergTableAdapter) -> Table:
     return Table(_JExplore.properties(ita.j_object.icebergTable()))


 def statistics_files(ita: IcebergTableAdapter) -> Table:
     return Table(_JExplore.statisticsFiles(ita.j_object.icebergTable()))


 def partition_statistics_files(ita: IcebergTableAdapter) -> Table:
     return Table(_JExplore.partitionStatisticsFiles(ita.j_object.icebergTable()))


 def partition_stats(ita: IcebergTableAdapter) -> Table:
     return Table(_JExplore.partitionStats(ita.j_object.icebergTable(), ita.j_object.icebergTable().currentSnapshot()))

  • Constructor Details

    • Explore

      public Explore()

  • Method Details

    • snapshots

      public static Table snapshots(org.apache.iceberg.Table table)

    • snapshots

      public static Table snapshots(Collection<org.apache.iceberg.Snapshot> snapshots)

    • manifestFiles

      public static Table manifestFiles(org.apache.iceberg.Table table)

    • manifestFiles

      public static Table manifestFiles(org.apache.iceberg.Snapshot snapshot, org.apache.iceberg.io.FileIO io)

    • manifestFiles

      public static Table manifestFiles(Collection<org.apache.iceberg.ManifestFile> manifestFiles)

    • contentFiles

      public static Table contentFiles(org.apache.iceberg.Table table) throws IOException
      Throws:
      IOException

    • contentFiles

      public static Table contentFiles(Iterable<org.apache.iceberg.Snapshot> snapshots, org.apache.iceberg.io.FileIO io) throws IOException
      Throws:
      IOException

    • contentFiles

      public static Table contentFiles(org.apache.iceberg.Snapshot snapshot, org.apache.iceberg.io.FileIO io) throws IOException
      Throws:
      IOException

    • contentFiles

      public static Table contentFiles(Collection<org.apache.iceberg.ContentFile> dataFiles)

    • dataFiles

      public static Table dataFiles(org.apache.iceberg.ManifestFile manifestFile, org.apache.iceberg.io.FileIO io) throws IOException
      Throws:
      IOException

    • deleteFiles

      public static Table deleteFiles(org.apache.iceberg.ManifestFile manifestFile, org.apache.iceberg.io.FileIO io) throws IOException
      Throws:
      IOException

    • refs

      public static Table refs(org.apache.iceberg.Table table)

    • refs

      public static Table refs(Map<String,org.apache.iceberg.SnapshotRef> refs)

    • statisticsFiles

      public static Table statisticsFiles(org.apache.iceberg.Table table)

    • statisticsFiles

      public static Table statisticsFiles(Collection<org.apache.iceberg.StatisticsFile> values)

    • partitionStatisticsFiles

      public static Table partitionStatisticsFiles(org.apache.iceberg.Table table)

    • partitionStatisticsFiles

      public static Table partitionStatisticsFiles(Collection<org.apache.iceberg.PartitionStatisticsFile> values)

    • properties

      public static Table properties(org.apache.iceberg.Table table)

    • properties

      public static Table properties(Map<String,String> properties)

    • partitionStats

      public static Table partitionStats(org.apache.iceberg.Table table, org.apache.iceberg.Snapshot snapshot)

    • manifestFilesDeduped

      public static Collection<org.apache.iceberg.ManifestFile> manifestFilesDeduped(Iterable<org.apache.iceberg.Snapshot> snapshots, org.apache.iceberg.io.FileIO io)

    • readDataFiles

      public static List<org.apache.iceberg.DataFile> readDataFiles(org.apache.iceberg.ManifestFile manifestFile, org.apache.iceberg.io.FileIO io) throws IOException
      Throws:
      IOException

    • readDeleteFiles

      public static List<org.apache.iceberg.DeleteFile> readDeleteFiles(org.apache.iceberg.ManifestFile manifestFile, org.apache.iceberg.io.FileIO io) throws IOException
      Throws:
      IOException