in flink-connector-hbase-1.4/src/main/java/org/apache/flink/connector/hbase1/source/HBaseDynamicTableSource.java [61:72]
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)
&& Objects.equals(cache, that.cache);
}