statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/EgressType.java [40:68]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    this.namespace = Objects.requireNonNull(namespace);
    this.type = Objects.requireNonNull(type);
  }

  /**
   * Returns the namespace of this egress type.
   *
   * @return the namespace of this egress type.
   */
  public String namespace() {
    return namespace;
  }

  /**
   * Returns the name of this egress type.
   *
   * @return the name of this egress type.
   */
  public String type() {
    return type;
  }

  @Override
  public boolean equals(Object o) {
    if (this == o) {
      return true;
    }
    if (o == null || getClass() != o.getClass()) {
      return false;
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/IngressType.java [40:68]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    this.namespace = Objects.requireNonNull(namespace);
    this.type = Objects.requireNonNull(type);
  }

  /**
   * Returns the namespace of this ingress type.
   *
   * @return the namespace of this ingress type.
   */
  public String namespace() {
    return namespace;
  }

  /**
   * Returns the name of this ingress type.
   *
   * @return the name of this ingress type.
   */
  public String type() {
    return type;
  }

  @Override
  public boolean equals(Object o) {
    if (this == o) {
      return true;
    }
    if (o == null || getClass() != o.getClass()) {
      return false;
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -