草庐IT

JavaDStream

全部标签

java - 如何使用 Java 将 JavaDStream<String> 存储到 spark 中的 Hive 表?

我正在将来自Kafka服务器的消息接收到JavaDStream对象中。现在我想将消息存储到配置单元表中。我该怎么做?从Kafka流接收消息的代码片段:JavaPairReceiverInputDStreamkafkaStream=KafkaUtils.createStream(jssc,zookeperIp,consumerGroup,topic);JavaDStreammessageData=kafkaStream.map(newFunction,String>(){@OverridepublicStringcall(Tuple2message)throwsException{//T