MessageStream getRegisteredMessageStream(int id) {
    return this.registeredStreams.get(id);
  }
Base class for all unit tests for translators
samza-sql/src/test/java/org/apache/samza/sql/translator/TranslatorTestBase.java