It seems that the second problem is dependency issue.
and it works exactly like the first one.
*this is the complete code:*
JavaSchemaRDD schemas=ctx.jsonRDD(arg0);
schemas.insertInto("test", true);
JavaSchemaRDD teeagers=ctx.hql("SELECT a,b FROM test");
List<String> teeagerNames1=teeagers.map(new Function<Row,String>()
{
/**
*
*/
private
static final long serialVersionUID = 1L;
@Override
public
String call(Row arg1) throws Exception {
// TODO Auto-generated method stub
System.out.println(arg1.length());
System.out.println("Name:"+arg1.getString(0));
System.out.println("Name:"+arg1.getString(1));
return "Name:"+arg1.getString(0);
}
}).collect();
the input is :
{"a":"111","b":"222"}
{"a":"111","b":"222"}
the output is:
2
Name:111
Name:222
while from hive:
hive> select * from test;
OK
111 NULL
111 NULL
so,what's going wrong?
thank you.
--
View this message in context:
http://apache-spark-user-list.1001560.n3.nabble.com/a-hivectx-insertinto-issue-tp16365p16376.html
Sent from the Apache Spark User List mailing list archive at Nabble.com.
---------------------------------------------------------------------
To unsubscribe, e-mail: user-unsubscr...@spark.apache.org
For additional commands, e-mail: user-h...@spark.apache.org
