初めてのSpark

181

9.4　JDBC/ODBC サーバー

public HappyPerson(String n, String b) {

name = n; favouriteBeverage = b;

}

public String getName() { return name; }

public void setName(String n) { name = n; }

public String getFavouriteBeverage() { return favouriteBeverage; }

public void setFavouriteBeverage(String b) { favouriteBeverage = b; }

};

...

ArrayList<HappyPerson> peopleList = new ArrayList<HappyPerson>();

peopleList.add(new HappyPerson("holden", "coffee"));

JavaRDD<HappyPerson> happyPeopleRDD = sc.parallelize(peopleList);

SchemaRDD happyPeopleSchemaRDD = hiveCtx.applySchema(happyPeopleRDD,

HappyPerson.class);

happyPeopleSchemaRDD.registerTempTable("happy_people"); ...