@Override
    public FulfilledOrderRecord apply(OrderRecord message, ShipmentRecord otherMessage) {
      return new FulfilledOrderRecord(message.orderId, message.orderTimeMs, otherMessage.shipTimeMs);
    }
Simple 2-way stream-to-stream join example
samza-test/src/main/java/org/apache/samza/example/OrderShipmentJoinExample.java