fix(bin): Expose needed types public (#108)

Signed-off-by: Xuanwo <[email protected]>

src/bin/orc-export.rs

@@ -34,6 +34,7 @@ enum FileFormat {
     Json,
 }
 
+#[allow(clippy::large_enum_variant)]
 enum OutputWriter<W: io::Write, F: JsonFormat> {
     Csv(csv::Writer<W>),
     Json(json::Writer<W, F>),
@@ -121,7 +122,7 @@ fn main() -> Result<()> {
 
         // Have we reached limit on the number of rows?
         if num_rows > batch.num_rows() as u64 {
-            num_rows = num_rows - batch.num_rows() as u64;
+            num_rows -= batch.num_rows() as u64;
         } else {
             break;
         }

src/bin/orc-stats.rs

@@ -92,7 +92,7 @@ fn print_column_stats(col_stats: &ColumnStatistics) {
 
     println!("* Num values: {}", col_stats.number_of_values());
     println!("* Has nulls: {}", col_stats.has_null());
-    println!("");
+    println!();
 }
 
 fn main() -> Result<()> {

src/reader/decompress.rs

@@ -267,7 +267,7 @@ impl FallibleStreamingIterator for DecompressorIter {
 }
 
 /// A [`Read`]er fulfilling the ORC specification of reading compressed data.
-pub(crate) struct Decompressor {
+pub struct Decompressor {
     decompressor: DecompressorIter,
     offset: usize,
     is_first: bool,

src/stripe.rs

@@ -88,7 +88,7 @@ impl TryFrom<(&proto::StripeInformation, &proto::StripeStatistics)> for StripeMe
 }
 
 #[derive(Debug)]
-pub(crate) struct Stripe {
+pub struct Stripe {
     columns: Vec<Column>,
     /// <(ColumnId, Kind), Bytes>
     stream_map: Arc<StreamMap>,
@@ -218,7 +218,7 @@ impl Stripe {
 }
 
 #[derive(Debug)]
-pub(crate) struct StreamMap {
+pub struct StreamMap {
     pub inner: HashMap<(u32, Kind), Bytes>,
     pub compression: Option<Compression>,
 }