阅读背景:

是否可以从PubSub读取消息并将其数据分离到PCollection 的不同元素中?如果是这样,怎么样?

来源:互联网 

Now, I have the below code:

现在,我有以下代码:

PCollection<String> input_data =
    pipeline
        .apply(PubsubIO
            .Read
            .withCoder(StringUtf8Coder.of())
            .named("ReadFromPubSub")
            .subscription("/subscriptions/project_name/subscription_name"));
PCol



你的当前访问异常,请进行认证后继续阅读剩余内容。

分享到: