@Override
    public String getFirstKey(OrderRecord message) {
      return message.orderId;
    }
Simple 2-way stream-to-stream join example
samza-test/src/main/java/org/apache/samza/example/OrderShipmentJoinExample.java