flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/AbstractTimeIndexGenerator.java [26:39]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
@Internal
abstract class AbstractTimeIndexGenerator extends IndexGeneratorBase {

    private final String dateTimeFormat;
    protected transient DateTimeFormatter dateTimeFormatter;

    public AbstractTimeIndexGenerator(String index, String dateTimeFormat) {
        super(index);
        this.dateTimeFormat = dateTimeFormat;
    }

    @Override
    public void open() {
        this.dateTimeFormatter = DateTimeFormatter.ofPattern(dateTimeFormat);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/AbstractTimeIndexGenerator.java [26:39]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
@Internal
abstract class AbstractTimeIndexGenerator extends IndexGeneratorBase {

    private final String dateTimeFormat;
    protected transient DateTimeFormatter dateTimeFormatter;

    public AbstractTimeIndexGenerator(String index, String dateTimeFormat) {
        super(index);
        this.dateTimeFormat = dateTimeFormat;
    }

    @Override
    public void open() {
        this.dateTimeFormatter = DateTimeFormatter.ofPattern(dateTimeFormat);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -