Do we have a list of breaking changes (from the Google Dataflow SDK to Beam), because this is going to be important considering other recent breaking changes, for example this two that I found yesterday too:
DirectPipelineRunner -> DirectRunner DoFnTester.processBatch -> DoFnTester.processBundle (?) Ismael. On Fri, Jun 17, 2016 at 9:19 AM, Jean-Baptiste Onofré <[email protected]> wrote: > Hi guys, > > I tested the latest Beam SNAPSHOT this morning and a code which was > working yesterday is not broken with the last changes. > > I'm using a filter by predicate: > > .apply("Filtering", Filter.byPredicate(new > SerializableFunction<String, Boolean>() { > public Boolean apply(String input) { > ... > })). > > The filter method has been renamed from byPredicate() to by(). > > Just to let others know that it can impact their pipelines. > > Regards > JB > -- > Jean-Baptiste Onofré > [email protected] > http://blog.nanthrax.net > Talend - http://www.talend.com >
