PySpark Kafka结构化的空输出,用于groupBy聚合

问题描述

我正在尝试对kafka数据进行结构化的流聚合/ groupBy。我正在研究(Py)Spark 2.4.6。但是无论哪种模式,我的输出都为空。

python伪代码

class App extends Component {
constructor(props) {
super(props);
this.state = {
  loading: false,buttonStatus: 'Post room',value: '',}
}

PostANewRoomScreen = () => {
let {data} = '';
return (
<View style={{padding: 15}}>
      <TouchableOpacity
      style={styles.button}
      disabled={this.state.loading}
      onPress={() => this.postroom(data)}  
      >
      <Text style={{color: "white",fontSize: hp('2.5%'),padding: 5}}>
      {this.state.loading && <Animated.Image style={{height: hp('3%'),width: wp('2%')}} source={{uri: 'https://media0.giphy.com/media/JTVkOqJ1RyYEBnyoRb/giphy.gif'}} />}
        {this.state.buttonStatus}
        </Text>
      </TouchableOpacity>
    </View> 

postroom = (value) => {
    this.state.loading = true;
    this.state.buttonStatus = "button clicked!";
}

我得到以下输出

MaxBy

不确定我在哪里缺少什么。

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@)