Skip to content
This repository has been archived by the owner on Aug 24, 2019. It is now read-only.

Commit

Permalink
Browse files Browse the repository at this point in the history
  • Loading branch information
alecmocatta committed Jan 11, 2019
1 parent aeefb59 commit 41896b5
Show file tree
Hide file tree
Showing 5 changed files with 1,815 additions and 18 deletions.
3 changes: 3 additions & 0 deletions src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -124,6 +124,9 @@
#![feature(rustc_private)]
#![feature(specialization)]
#![feature(try_from)]
#![feature(existential_type)]
#![feature(maybe_uninit)]
#![feature(nll)]
#![allow(dead_code)]
#![allow(non_camel_case_types)]

Expand Down
24 changes: 23 additions & 1 deletion src/record/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -20,6 +20,28 @@
mod api;
pub mod reader;
mod triplet;
pub mod schemas;
pub mod types;

use std::{fmt,fmt::Debug};
use schema::types::ColumnDescPtr;
use schema::types::ColumnPath;
use std::collections::HashMap;
use errors::ParquetError;
use schema::types::Type;
use record::reader::Reader;
use column::reader::ColumnReader;
// pub use self::api::{List, ListAccessor, Map, MapAccessor, Row, RowAccessor};
pub use self::triplet::TypedTripletIter;
// pub use self::triplet::TypedTripletIter;

pub trait DebugType {
fn fmt(f: &mut fmt::Formatter) -> Result<(), fmt::Error>;
}

pub trait Deserialize: Sized {
type Schema: Debug + DebugType;
type Reader: Reader<Item = Self>;

fn parse(schema: &Type) -> Result<(String,Self::Schema),ParquetError>;
fn reader(schema: &Self::Schema, mut path: &mut Vec<String>, curr_def_level: i16, curr_rep_level: i16, paths: &mut HashMap<ColumnPath, (ColumnDescPtr,ColumnReader)>) -> Self::Reader;
}
Loading

0 comments on commit 41896b5

Please sign in to comment.