docs: private void updateStreamStatus( Set<String> exportedTables) {
          synchronized(m_dataSourcesByPartition) {
              for (Iterator<Map<String, ExportDataSource>> it = m_dataSourcesByPartition.values().iterator(); it.hasNext();) {
                  Map<String, ExportDataSource> sources = it.next();
                  for (String tableName: sources.keySet()) {
                      ExportDataSource src = sources.get(tableName);
                      if (!exportedTables.contains(tableName)) {
                          src.setStatus(ExportDataSource.StreamStatus.DROPPED);
                      } else if (src.getStatus() == ExportDataSource.StreamStatus.DROPPED) {
                          src.setStatus(ExportDataSource.StreamStatus.ACTIVE);
                      }
                  }
              }
          }
      }