Skip to content

Commit

Permalink
Remove unimplemented flight sql method
Browse files Browse the repository at this point in the history
  • Loading branch information
lewiszlw committed Apr 16, 2024
1 parent 11a35c6 commit ffe35c9
Showing 1 changed file with 1 addition and 11 deletions.
12 changes: 1 addition & 11 deletions ballista/scheduler/src/flight_sql.rs
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@ use arrow_flight::flight_service_server::FlightService;
use arrow_flight::sql::server::{FlightSqlService, PeekableFlightDataStream};
use arrow_flight::sql::{
ActionClosePreparedStatementRequest, ActionCreatePreparedStatementRequest,
ActionCreatePreparedStatementResult, CommandGetSqlInfo, CommandGetTableTypes, CommandGetTables,
ActionCreatePreparedStatementResult, CommandGetTableTypes, CommandGetTables,
CommandPreparedStatementQuery, CommandPreparedStatementUpdate, CommandStatementQuery, SqlInfo,
};
use arrow_flight::{
Expand Down Expand Up @@ -643,16 +643,6 @@ impl FlightSqlService for FlightSqlServiceImpl {
Ok(resp)
}

async fn get_flight_info_sql_info(
&self,
_query: CommandGetSqlInfo,
_request: Request<FlightDescriptor>,
) -> Result<Response<FlightInfo>, Status> {
debug!("get_flight_info_sql_info");
// TODO: implement for FlightSQL JDBC to work
Err(Status::unimplemented("Implement CommandGetSqlInfo"))
}

async fn do_put_prepared_statement_update(
&self,
handle: CommandPreparedStatementUpdate,
Expand Down

0 comments on commit ffe35c9

Please sign in to comment.