File tree Expand file tree Collapse file tree
modelardb_embedded/src/operations Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -39,7 +39,7 @@ use crate::operations::{
3939} ;
4040use crate :: { Aggregate , TableType } ;
4141
42- /// [`DataSink`] that rejects INSERT statements passed to [`DataFolder .read()`].
42+ /// [`DataSink`] that rejects INSERT statements passed to [`Operations .read()`].
4343pub struct DataFolderDataSink {
4444 /// The schema of the data sink is empty since it rejects everything.
4545 schema : Arc < Schema > ,
Original file line number Diff line number Diff line change @@ -161,8 +161,8 @@ impl Context {
161161
162162 /// Register the normal table with `table_name` in Apache DataFusion. If the normal table does
163163 /// not exist or could not be registered with Apache DataFusion, return
164- /// [`ModelarDbServerError`]. [`DataFolder.register_normal_and_time_series_tables ()`] is not
165- /// used so a unique [`NormalTableDataSink`] can be passed per table.
164+ /// [`ModelarDbServerError`]. [`DataFolder.register_tables ()`] is not used so a unique
165+ /// [`NormalTableDataSink`] can be passed per table.
166166 async fn register_normal_table ( & self , table_name : & str ) -> Result < ( ) > {
167167 let session_context = self . data_folders . query_data_folder . session_context ( ) ;
168168
@@ -211,8 +211,8 @@ impl Context {
211211
212212 /// Register the time series table with `time_series_table_metadata` in Apache DataFusion. If
213213 /// the time series table does not exist or could not be registered with Apache DataFusion,
214- /// return [`ModelarDbServerError`]. [`DataFolder.register_normal_and_time_series_tables ()`] is
215- /// not used so a unique [`TimeSeriesTableDataSink`] can be passed per table.
214+ /// return [`ModelarDbServerError`]. [`DataFolder.register_tables ()`] is not used so a unique
215+ /// [`TimeSeriesTableDataSink`] can be passed per table.
216216 async fn register_time_series_table (
217217 & self ,
218218 time_series_table_metadata : Arc < TimeSeriesTableMetadata > ,
Original file line number Diff line number Diff line change @@ -227,8 +227,8 @@ pub fn flight_data_to_record_batch(
227227 . map_err ( |error| Status :: invalid_argument ( error. to_string ( ) ) )
228228}
229229
230- /// Return the table stored as the first element in [ `FlightDescriptor.path`] , otherwise a
231- /// [`Status`] that specifies that the table name is missing.
230+ /// Return the table stored as the first element in `FlightDescriptor.path`, otherwise a [`Status`]
231+ /// that specifies that the table name is missing.
232232pub fn table_name_from_flight_descriptor (
233233 flight_descriptor : & FlightDescriptor ,
234234) -> StdResult < & String , Status > {
You can’t perform that action at this time.
0 commit comments