Dataflow BigTable 按运行时定义的前缀读取行

如何解决Dataflow BigTable 按运行时定义的前缀读取行

我正在使用 Google Dataflow 根据行前缀从 BigTable 读取行，并且需要在管道运行之间更改前缀。我没有成功地尝试参数化扫描配置，因为显然没有办法将 ValueProvider 传递给将携带运行时参数的扫描配置。

这是提供静态前缀的扫描配置的代码片段：

   // Scan config definition
    private static CloudBigtableScanConfiguration getCloudBigtableScanConfiguration(CatalogPipelineOptions options) {
        Scan scan = new Scan()
            .setCacheBlocks(false)
            .setFilter(
                // FIXME: How to provide the prefix at runtime/when executing the dataflow template?
                new PrefixFilter("prefix-changed-at-runtime-".getBytes())
            );

        return new CloudBigtableScanConfiguration.Builder()
            .withProjectId(options.getBigtableProjectId())
            .withInstanceId(options.getBigtableInstanceId())
            .withTableId(options.getBigtableTableId())
            .withScan(scan)
            .build();
    }
  
   // Use of the scan config
    pipeline.apply("Read from BigTable",Read.from(
        CloudBigtableIO.read(getCloudBigtableScanConfiguration(options)))
    );

有没有办法将运行时参数传递给扫描配置而不依赖于管道构建期间定义的单个值？