flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/IndexGeneratorBase.java [26:50]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
@Internal
public abstract class IndexGeneratorBase implements IndexGenerator {

    private static final long serialVersionUID = 1L;
    protected final String index;

    public IndexGeneratorBase(String index) {
        this.index = index;
    }

    @Override
    public boolean equals(Object o) {
        if (this == o) {
            return true;
        }
        if (!(o instanceof IndexGeneratorBase)) {
            return false;
        }
        IndexGeneratorBase that = (IndexGeneratorBase) o;
        return index.equals(that.index);
    }

    @Override
    public int hashCode() {
        return Objects.hash(index);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/IndexGeneratorBase.java [26:50]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
@Internal
public abstract class IndexGeneratorBase implements IndexGenerator {

    private static final long serialVersionUID = 1L;
    protected final String index;

    public IndexGeneratorBase(String index) {
        this.index = index;
    }

    @Override
    public boolean equals(Object o) {
        if (this == o) {
            return true;
        }
        if (!(o instanceof IndexGeneratorBase)) {
            return false;
        }
        IndexGeneratorBase that = (IndexGeneratorBase) o;
        return index.equals(that.index);
    }

    @Override
    public int hashCode() {
        return Objects.hash(index);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -