I assume you have the dictionary in memory? If so, you can do
pcoll = p | beam.Create(my_dict.items())
On Wed, Jun 5, 2019 at 8:10 AM Anjana Pydi <[email protected]> wrote:
>
> Hi,
>
> Can some one please let me know how to convert a dictionary / JSON to a
> pcollection ?
>
> Thanks,
> Anjana
> -----------------------------------------------------------------------------------------------------------------------
> The information contained in this communication is intended solely for the
> use of the individual or entity to whom it is addressed and others authorized
> to receive it. It may contain confidential or legally privileged information.
> If you are not the intended recipient you are hereby notified that any
> disclosure, copying, distribution or taking any action in reliance on the
> contents of this information is strictly prohibited and may be unlawful. If
> you are not the intended recipient, please notify us immediately by
> responding to this email and then delete it from your system. Bahwan Cybertek
> is neither liable for the proper and complete transmission of the information
> contained in this communication nor for any delay in its receipt.
