Do you actually need the `TSConfiguration` class, and pass its instances around? I would recommend doing the following instead: * convert `TSConfiguration` to `PipelineOptions` interface and combine it with `TimeSeriesOptions`, see `NexmarkOptions` for example; * inherit from existing options like `GcpOptions` that already have things like `projectId`; * give meaningful defaults to the values; * don't pass the configuration around but get the `PipelineOptions` directly in the `PTransform.expand()` implementations, like `input.getPipeline().getOptions().as(YourPipelineOptions.class)`. Or in `DoFns` I think there's `c.getPipelineOptions().as(...)` in `@ProcessElement` method as well;
[ Full content available at: https://github.com/apache/beam/pull/6540 ] This message was relayed via gitbox.apache.org for [email protected]
