Yash Agarwal
01/17/2022, 10:05 AMKartik Khare
01/17/2022, 10:07 AMYash Agarwal
01/17/2022, 10:08 AM@Bean
public DataSource pinotDatabase(PinotConfig pinotConfig) {
Map<String, PinotClientProperties> clients = pinotConfig.getClients();
Optional<PinotClientProperties> client = clients.values().stream().findFirst();
String host;
if (client.isPresent()) {
host = String.format("jdbc:<pinot://%s:%s>", client.get().getHosts().get(0), client.get().getPort());
} else {
throw new DataLabException(false,
"Unable to find cluster name configured under key 'pinot.clients' in application.yml.");
}
DriverManagerDataSource dataSource = new DriverManagerDataSource();
dataSource.setUrl(host);
dataSource.setDriverClassName("org.apache.pinot.client.PinotDriver");
return dataSource;
}Yash Agarwal
01/17/2022, 10:09 AMdataSource.setUsername("username");
dataSource.setPassword("password");Kartik Khare
01/17/2022, 10:09 AMYash Agarwal
01/17/2022, 10:10 AMKartik Khare
01/17/2022, 10:10 AMYash Agarwal
01/17/2022, 10:15 AM