如何给hive设置read-commit

发布网友发布时间：2024-04-29 21:40

共1个回答

热心网友时间：2024-04-30 00:55

class LogClient(object): def __init__(self, kafkaHost, kafkaPort): self.kafkaHost = kafkaHost self.kafkaPort = kafkaPort def fixLen(self, s, l): s = s[0:8]+worknode+s[8:] fixed = s+" "*(l-len(s)) return fixed def sendLog(self, 。

声明：本网页内容为用户发布，旨在传播知识，不代表本网认同其观点，若有侵权等问题请及时与本网联系，我们将在第一时间删除处理。E-MAIL:11247931@qq.com