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é
jbono...@apache.org
http://blog.nanthrax.net
Talend - http://www.talend.com
