class StringTimestampExtractionPolicy implements TimestampExtractionPolicy {

  @Override
  public void applyTo(final KsqlConfig config,
                      final Map<String, Object> newStreamProperties) {
    newStreamProperties.put(
        KsqlConfig.KSQL_TIMESTAMP_COLUMN_INDEX,
        config.get(KsqlConfig.KSQL_TIMESTAMP_COLUMN_INDEX)
    );
    newStreamProperties.put(
        StreamsConfig.DEFAULT_TIMESTAMP_EXTRACTOR_CLASS_CONFIG,
        StringTimestampExtractor.class
    );
    newStreamProperties.put(KsqlConfig.STRING_TIMESTAMP_FORMAT, format);
  }

  @JsonCreator public  StringTimestampExtractionPolicy(
      @JsonProperty("timestampField") final String timestampField,
      @JsonProperty("format") final String format);

}