flink-connector-hbase-1.4/src/main/java/org/apache/flink/connector/hbase1/source/HBaseDynamicTableSource.java [57:70]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        return new HBaseRowDataInputFormat(conf, tableName, hbaseSchema, nullStringLiteral);
    }

    @Override
    public boolean equals(Object o) {
        if (!(o instanceof HBaseDynamicTableSource)) {
            return false;
        }
        HBaseDynamicTableSource that = (HBaseDynamicTableSource) o;
        return Objects.equals(conf, that.conf)
                && Objects.equals(tableName, that.tableName)
                && Objects.equals(hbaseSchema, that.hbaseSchema)
                && Objects.equals(nullStringLiteral, that.nullStringLiteral)
                && Objects.equals(maxRetryTimes, that.maxRetryTimes)
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



flink-connector-hbase-2.2/src/main/java/org/apache/flink/connector/hbase2/source/HBaseDynamicTableSource.java [103:116]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        return new HBaseRowDataInputFormat(conf, tableName, hbaseSchema, nullStringLiteral);
    }

    @Override
    public boolean equals(Object o) {
        if (!(o instanceof HBaseDynamicTableSource)) {
            return false;
        }
        HBaseDynamicTableSource that = (HBaseDynamicTableSource) o;
        return Objects.equals(conf, that.conf)
                && Objects.equals(tableName, that.tableName)
                && Objects.equals(hbaseSchema, that.hbaseSchema)
                && Objects.equals(nullStringLiteral, that.nullStringLiteral)
                && Objects.equals(maxRetryTimes, that.maxRetryTimes)
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -