Como especificar o dialeto sql ao criar o spark dataframe a partir do JDBC?
Estou com problemas para ler dados via JDBC personalizado com Spark. Como eu substitui o dialeto sql inferido via jdbc url?
O banco de dados em questão é vitess (https://github.com/youtube/vitess) que executa uma variante do mysql, então eu quero especificar um dialeto do mysql. O URL do jdbc começa com jdbc: vitess /
Caso contrário, o DataFrameReader está deduzindo um dialeto padrão que usa "" "como um identificador de cotação. Como resultado, consultas via spark.read.jdbc são enviadas como
Selecione 'id', 'col2', col3 ',' etc 'na tabela
que seleciona as representações de string em vez dos valores da coluna em vez de
Selecione id, col2, col3, etc da tabela