Skip to content

Commit

Permalink
Remove unused methods
Browse files Browse the repository at this point in the history
  • Loading branch information
karolisg committed Feb 13, 2023
1 parent ad3aa4a commit c725eec
Showing 1 changed file with 0 additions and 16 deletions.
16 changes: 0 additions & 16 deletions dozer-ingestion/src/connectors/datafusion/connector.rs
Original file line number Diff line number Diff line change
Expand Up @@ -54,10 +54,6 @@ impl Connector for DataFusionConnector<S3Storage> {
mapper.get_schema(tables)
}

fn get_tables(&self) -> Result<Vec<crate::connectors::TableInfo>, errors::ConnectorError> {
todo!()
}

fn initialize(
&mut self,
ingestor: Arc<RwLock<Ingestor>>,
Expand All @@ -84,10 +80,6 @@ impl Connector for DataFusionConnector<S3Storage> {

reader.read_tables(tables, ingestor)
}

fn stop(&self) {
todo!()
}
}

impl Connector for DataFusionConnector<LocalStorage> {
Expand Down Expand Up @@ -117,10 +109,6 @@ impl Connector for DataFusionConnector<LocalStorage> {
mapper.get_schema(tables)
}

fn get_tables(&self) -> Result<Vec<crate::connectors::TableInfo>, errors::ConnectorError> {
todo!()
}

fn initialize(
&mut self,
ingestor: Arc<RwLock<Ingestor>>,
Expand All @@ -147,8 +135,4 @@ impl Connector for DataFusionConnector<LocalStorage> {

reader.read_tables(tables, ingestor)
}

fn stop(&self) {
todo!()
}
}

0 comments on commit c725eec

Please sign in to comment.