MyFn with using factory option

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 
   }