@@ -85,12 +85,12 @@ fn create_sources(
8585) -> ( Instance , Instance ) {
8686 debug ! ( "Could not find environment variable `FED_CONFIG_PATH`, use manual configuration (c++ API only)!" ) ;
8787 let mut db_config = vec ! [ ] ;
88- let db_manual = jvm. create_instance ( "java.util.HashMap" , & [ ] ) ?;
88+ let db_manual = jvm. create_instance ( "java.util.HashMap" , InvocationArg :: empty ( ) ) ?;
8989
9090 for ( db_name, db_info) in db_map. iter ( ) {
9191 if db_info. manual_info . is_some ( ) {
9292 let manual_info = db_info. manual_info . as_ref ( ) . unwrap ( ) ;
93- let schema_info = jvm. create_instance ( "java.util.HashMap" , & [ ] ) ?;
93+ let schema_info = jvm. create_instance ( "java.util.HashMap" , InvocationArg :: empty ( ) ) ?;
9494 for ( name, columns) in manual_info {
9595 let arr_instance = jvm. java_list ( "java.lang.String" , columns. to_vec ( ) ) ?;
9696 jvm. invoke (
@@ -133,7 +133,7 @@ fn create_sources2(
133133) -> ( Instance , Instance ) {
134134 debug ! ( "Found environment variable `FED_CONFIG_PATH`, use configurations!" ) ;
135135 let mut dbs = vec ! [ ] ;
136- let db_manual = jvm. create_instance ( "java.util.HashMap" , & [ ] ) ?;
136+ let db_manual = jvm. create_instance ( "java.util.HashMap" , InvocationArg :: empty ( ) ) ?;
137137 for db in db_map. keys ( ) {
138138 dbs. push ( String :: from ( db) ) ;
139139 }
@@ -157,12 +157,15 @@ pub fn rewrite_sql(
157157 Ok ( _) => create_sources2 ( & jvm, db_map) ?,
158158 _ => create_sources ( & jvm, db_map) ?,
159159 } ;
160- let rewriter = jvm. create_instance ( "ai.dataprep.accio.FederatedQueryRewriter" , & [ ] ) ?;
160+ let rewriter = jvm. create_instance (
161+ "ai.dataprep.accio.FederatedQueryRewriter" ,
162+ InvocationArg :: empty ( ) ,
163+ ) ?;
161164 let db_config = InvocationArg :: try_from ( db_config) . unwrap ( ) ;
162165 let db_manual = InvocationArg :: try_from ( db_manual) . unwrap ( ) ;
163166 let plan = jvm. invoke ( & rewriter, "rewrite" , & [ sql, db_config, db_manual, strategy] ) ?;
164167
165- let count = jvm. invoke ( & plan, "getCount" , & [ ] ) ?;
168+ let count = jvm. invoke ( & plan, "getCount" , InvocationArg :: empty ( ) ) ?;
166169 let count: i32 = jvm. to_rust ( count) ?;
167170 debug ! ( "rewrite finished, got {} queries" , count) ;
168171
0 commit comments