Hi
I have developed a BigQuery Flink connector by
implementing DynamicTableSourceFactory.
I have a requirement to :
get the configured parallelism value of
StreamExecutionEnvironment in the Factory class.
or
set the parallelism at Factory class or Table source
class level.
Please help me on this.
Thanks and Regards,
Anitha Thankappan
--
_This message contains information that may be privileged or confidential
and is the property of the Quantiphi Inc and/or its affiliates_. It is
intended only for the person to whom it is addressed. _If you are not the
intended recipient, any review, dissemination, distribution, copying,
storage or other use of all or any portion of this message is strictly
prohibited. If you received this message in error, please immediately
notify the sender by reply e-mail and delete this message in its
*entirety*___
