private boolean checkWindowOrJoins() {
    Set<OperatorSpec> windowOrJoinSpecs = allOpSpecs.stream()
        .filter(spec -> spec.getOpCode() == OperatorSpec.OpCode.WINDOW || spec.getOpCode() == OperatorSpec.OpCode.JOIN)
        .collect(Collectors.toSet());

    return windowOrJoinSpecs.size() != 0;
  }
Returns a deserialized {@link OperatorSpecGraph} as a copy from this instance of {@link OperatorSpecGraph}
This is used to create per-task instance of {@link OperatorSpecGraph} when instantiating task instances.

@return a copy of this {@link OperatorSpecGraph} object via deserialization
samza-core/src/main/java/org/apache/samza/operators/OperatorSpecGraph.java