Added params to savePaths for spark dialect. (#2276)

Fixes #2275.

Author: chrisknoll

src/main/java/org/ohdsi/webapi/pathway/PathwayStatisticsTasklet.java

@@ -31,6 +31,7 @@
 import java.util.stream.Collectors;
 import java.util.stream.IntStream;
 import java.util.stream.Stream;
+import org.ohdsi.sql.SqlRender;
 import org.ohdsi.webapi.common.generation.CancelableTasklet;
 import org.ohdsi.webapi.util.PreparedStatementRendererCreator;
 import org.springframework.jdbc.core.PreparedStatementCreator;
@@ -170,6 +171,10 @@ private int[] savePathwayCodes(List<PathwayCode> pathwayCodes) {
 	private int[] savePaths(Source source, Long generationId) throws SQLException {
 		String sql = SAVE_PATHS_SQL;
 		if (source.getSourceDialect().equals("spark")) {
+			sql = SqlRender.renderSql(sql, 
+							new String[]{"target_database_schema", GENERATION_ID}, 
+							new String[]{source.getTableQualifier(SourceDaimon.DaimonType.Results), generationId.toString()}
+			);
 			sql = BigQuerySparkTranslate.sparkHandleInsert(sql, source.getSourceConnection());
 		}