public Multimap<SendToTableOperatorSpec, StreamTableJoinOperatorSpec> getSendToTableOpSpecToStreamTableJoinOpSpecs() {
      Multimap<SendToTableOperatorSpec, StreamTableJoinOperatorSpec> sendToTableOpSpecToStreamTableJoinOpSpecs =
          HashMultimap.create();

      // Map every SendToTableOperatorSpec to all StreamTableJoinOperatorSpecs referencing the same table.
      for (String tableId : tableToSendToTableOpSpecs.keySet()) {
        Collection<SendToTableOperatorSpec> sendToTableOpSpecs = tableToSendToTableOpSpecs.get(tableId);
        Collection<StreamTableJoinOperatorSpec> streamTableJoinOpSpecs =
            tableToStreamTableJoinOpSpecs.get(tableId);

        for (SendToTableOperatorSpec sendToTableOpSpec : sendToTableOpSpecs) {
          sendToTableOpSpecToStreamTableJoinOpSpecs.putAll(sendToTableOpSpec, streamTableJoinOpSpecs);
        }
      }

      return Multimaps.unmodifiableMultimap(sendToTableOpSpecToStreamTableJoinOpSpecs);
    }
An {@link OperatorSpec} visitor that records associations between every {@link SendToTableOperatorSpec}
and all {@link StreamTableJoinOperatorSpec}s that reference the same table.
samza-core/src/main/java/org/apache/samza/execution/OperatorSpecGraphAnalyzer.java