Here is a code example: List<TableRow> ss = Arrays.asList(session1, session2); PCollection<TableRow> sessions = p.apply(Create.of(ss)); PCollection<MetricsWithDimension> res = Job.runJob(sessions, "20200614", false, new ProductCatalog()); p.run();
On Wed, 8 Jul 2020 at 17:07, Kirill Zhdanovich <kzhdanov...@gmail.com> wrote: > Hi, > I want to test pipeline and the input for it is PCollection of TableRows. > I've created a test, and when I run it I get an error: > > java.lang.ClassCastException: class java.util.LinkedHashMap cannot be cast > to class com.google.api.services.bigquery.model.TableRow > > Is it a known issue? Thank you in advance > > -- > Best Regards, > Kirill > -- Best Regards, Kirill
