运用spotifySCIO编写Dataflow一个任务写入PubSub的流云存储,下面的两个例子e.g1和e.g2写PubSub流GCS,但得到以下错误的下面的代码 错误 Exception in thread "main" java.lang.IllegalArgumentException: Write can only be applied to a Bounded PCollection
我正在使用Scio/Bigtable/HBase与下面的这个示例项目验证错误。依赖关系树需要protobuf版本(2.5,2.6.1,3.0,3.1),并且似乎默认为3.2。我使用了sbt-assembly的阴影部分,不确定我是否正确。 我build.sbt: name := "scalalab"
version := "1.0"
scalaVersion := "2.11.8"
li