public void updateStatusCount(final String state, final int change) {
    updateStatusCount(KafkaStreams.State.valueOf(state), change);
  }
@Test
  public void shouldImplementHashCodeAndEqualsCorrectly() {
    final QueryStatusCount queryStatusCount1 = new QueryStatusCount(Collections.singletonMap(KsqlQueryStatus.ERROR, 2));
    final QueryStatusCount queryStatusCount2 = new QueryStatusCount(Collections.singletonMap(KsqlQueryStatus.RUNNING, 1));
    queryStatusCount2.updateStatusCount(KafkaStreams.State.ERROR, 2);
    final QueryStatusCount queryStatusCount3 = new QueryStatusCount();
    queryStatusCount3.updateStatusCount(KafkaStreams.State.ERROR, 2);

    new EqualsTester()
        .addEqualityGroup(queryStatusCount, queryStatusCount)
        .addEqualityGroup(queryStatusCount1, queryStatusCount3)
        .addEqualityGroup(queryStatusCount2)
        .testEquals();
  }