Skip to content

Instantly share code, notes, and snippets.

@brachi-wernick

brachi-wernick/MyFn.java

Last active February 7, 2020 11:58
Show Gist options
  • Save brachi-wernick/6156314ddf07907d35433b530db3560e to your computer and use it in GitHub Desktop.
Save brachi-wernick/6156314ddf07907d35433b530db3560e to your computer and use it in GitHub Desktop.
Download ZIP
MyFn with using factory option
Raw
MyFn.java
public class MyFn extends DoFn<String, String> {
@ProcessElement
public void processElement(ProcessContext context,PipelineOptions options) {
RedisOptions redisOptions = options.as(RedisOptions.class);
RedissonClient redissonClient = redisOptions.getRedissonClient();
//some logic enrichment
redis.get()
// output
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment