dataflow/src/main/java/io/blockchainetl/common/fns/TimestampParserRepository.java
package io.blockchainetl.common.fns;

import java.util.HashMap;
import java.util.Map;

/**
 * Hack. Because in Dataflow/Beam all Fns must be serializable. Will inject in Fn only parser key. 
 */
public class TimestampParserRepository {
    
    public static final Map<String, TimestampParser> PARSERS = new HashMap<>();

    public static final String KEY_UNIX = "unix";

    static {
        PARSERS.put(KEY_UNIX, new UnixTimestampParser());
    }
}
