@@ -39,9 +39,13 @@ mod parquet_field;
39
39
///
40
40
/// Example:
41
41
///
42
- /// ```ignore
42
+ /// ```no_run
43
+ /// use parquet_derive::ParquetRecordWriter;
44
+ /// use std::io::{self, Write};
43
45
/// use parquet::file::properties::WriterProperties;
44
46
/// use parquet::file::writer::SerializedFileWriter;
47
+ /// use parquet::record::RecordWriter;
48
+ /// use std::fs::File;
45
49
///
46
50
/// use std::sync::Arc;
47
51
///
@@ -62,14 +66,15 @@ mod parquet_field;
62
66
/// a_str: "I'm false"
63
67
/// }
64
68
/// ];
69
+ /// let file = File::open("some_file.parquet").unwrap();
65
70
///
66
- /// let schema = samples.as_slice().schema();
71
+ /// let schema = samples.as_slice().schema().unwrap() ;
67
72
///
68
73
/// let mut writer = SerializedFileWriter::new(file, schema, Default::default()).unwrap();
69
74
///
70
75
/// let mut row_group = writer.next_row_group().unwrap();
71
76
/// samples.as_slice().write_to_row_group(&mut row_group).unwrap();
72
- /// writer.close_row_group(row_group ).unwrap();
77
+ /// row_group.close( ).unwrap();
73
78
/// writer.close().unwrap();
74
79
/// }
75
80
/// ```
@@ -148,9 +153,11 @@ pub fn parquet_record_writer(input: proc_macro::TokenStream) -> proc_macro::Toke
148
153
///
149
154
/// Example:
150
155
///
151
- /// ```ignore
156
+ /// ```no_run
157
+ /// use parquet::record::RecordReader;
152
158
/// use parquet::file::{serialized_reader::SerializedFileReader, reader::FileReader};
153
159
/// use parquet_derive::{ParquetRecordReader};
160
+ /// use std::fs::File;
154
161
///
155
162
/// #[derive(ParquetRecordReader)]
156
163
/// struct ACompleteRecord {
@@ -160,6 +167,7 @@ pub fn parquet_record_writer(input: proc_macro::TokenStream) -> proc_macro::Toke
160
167
///
161
168
/// pub fn read_some_records() -> Vec<ACompleteRecord> {
162
169
/// let mut samples: Vec<ACompleteRecord> = Vec::new();
170
+ /// let file = File::open("some_file.parquet").unwrap();
163
171
///
164
172
/// let reader = SerializedFileReader::new(file).unwrap();
165
173
/// let mut row_group = reader.get_row_group(0).unwrap();
0 commit comments