mosche commented on code in PR #24288:
URL: https://github.com/apache/beam/pull/24288#discussion_r1037811427
##########
runners/spark/3/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/TransformTranslator.java:
##########
@@ -56,13 +57,13 @@
*/
@Internal
public abstract class TransformTranslator<
- InT extends PInput, OutT extends POutput, TransformT extends PTransform<?
extends InT, OutT>> {
+ InT extends PInput, OutT extends POutput, TransformT extends PTransform<?
super InT, OutT>> {
Review Comment:
That was to better support the signature of `AppliedPTransform`, though
simplified this to just `InT` to match either direction
```
AppliedPTransform<
InputT extends PInput,
OutputT extends POutput,
TransformT extends PTransform<? super InputT, OutputT>>
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
