docs: private List<Integer> admitBoltTuple(String streamId,
                                         Collection<Tuple> anchors,
                                         List<Object> tuple,
                                         Integer emitDirectTaskId) {
      if (getPhysicalPlanHelper().isTerminatedComponent()) {
        // No need to handle this tuple
        return null;
      }
  
      // Start construct the data tuple
      HeronTuples.HeronDataTuple.Builder bldr = initTupleBuilder(streamId, tuple, emitDirectTaskId);
  
      // Set the anchors for a tuple
      if (anchors != null) {
        // This message is rooted
        Set<HeronTuples.RootId> mergedRoots = new HashSet<>();
        for (Tuple tpl : anchors) {
          if (tpl instanceof TupleImpl) {
            TupleImpl t = (TupleImpl) tpl;
            mergedRoots.addAll(t.getRoots());
          }
        }
        for (HeronTuples.RootId rt : mergedRoots) {
          bldr.addRoots(rt);
        }
      }
  
      sendTuple(bldr, streamId, tuple);
  
      // TODO:- remove this after changing the API
      return null;
    }