Hello,
There is not yet support for an Unbounded source for Mongo (streams) in Beam yet. You can track (or contribute to) the progress of the support on this JIRA: https://issues.apache.org/jira/browse/BEAM-2639 On Tue, Nov 6, 2018 at 9:02 AM Chaim Turkel <ch...@behalf.com> wrote: > > Hi, > I am looking for a way to move my batch process of moving data from > mongo to bigquery via streaming. > Does the MongoIO support streaming changes from mongo., if yes how > do you configure the query to check always for changes? > > chaim > > -- > > > Loans are funded by > FinWise Bank, a Utah-chartered bank located in Sandy, > Utah, member FDIC, Equal > Opportunity Lender. Merchant Cash Advances are > made by Behalf. For more > information on ECOA, click here > <https://www.behalf.com/legal/ecoa/>. For important information about > opening a new > account, review Patriot Act procedures here > <https://www.behalf.com/legal/patriot/>. > Visit Legal > <https://www.behalf.com/legal/> to > review our comprehensive program terms, > conditions, and disclosures.
