streamGraph.addOperator(transform.getId(),
        slotSharingGroup,
        transform.getCoLocationGroupKey(),
        transform.getOperatorFactory(),
        transform.getInputType(),
        transform.getOutputType(),
        transform.getName());


for (Integer inputId: inputIds) {
  streamGraph.addEdge(inputId, transform.getId(), 0);
}