Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- String myDriver = "com.mysql.jdbc.Driver";
- String myUrl = "jdbc:mysql://localhost:3306/rsds_data";
- Class.forName(myDriver);
- Connection conn = DriverManager.getConnection(myUrl, "root", "");
- String query = "SELECT * FROM slowa_kluczowe";
- Statement st = conn.createStatement();
- ResultSet rs = st.executeQuery(query);
- List<Row> rows = new ArrayList<>();
- rs.next();
- Row row = RowFactory.create(JdbcRDD.resultSetToObjectArray(rs));
- rows.add(row);
- Dataset<Row> df = sparkSession.createDataFrame(rows, jdbcDF.schema());
- df.printSchema();
- df.show();
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement