[FLINK-17445] Allow OperatorTransformation to bootstrapWith a Scala DataSet

• Type: Improvement
• Status: Closed
• Priority: Not a Priority
• Resolution: Won't Fix
• Affects Version/s: 1.10.0, 1.11.0
• Component/s: API / State Processor
• Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned pull-request-available
• Assignee: Unassigned
• Reporter: Brandon Bevans
• Created: 28/Apr/20 22:06
• Updated: 11/Nov/22 15:12
• Resolved: 11/Nov/22 15:12

Description

Currently there is no way to use OperatorTransformation.bootstrapWith using a Scala DataSet. The functionality does seem to be there since a Scala DataSet appears to just be a wrapped Java DataSet. This functionality could be achieved with minimal invasiveness by passing through the underlying Java DataSet to the call.

 

Also, the docs suggest that this function should work:

From https://ci.apache.org/projects/flink/flink-docs-stable/dev/libs/state_processor_api.html:

val currencyDataSet = bEnv.fromCollection(CurrencyRate("USD", 1.0), CurrencyRate("EUR", 1.3)) val broadcastTransformation = OperatorTransformation .bootstrapWith(currencyDataSet) .transform(new CurrencyBootstrapFunction)

I would love to take this issue on.

Issue Links

• links to: GitHub Pull Request #12285