public static byte[] getQueueRowPrefix(QueueName queueName) {
    if (queueName.isStream()) {
      // NOTE: stream is uniquely identified by table name
      return Bytes.EMPTY_BYTE_ARRAY;
    }
    String flowlet = queueName.getThirdComponent();
    String output = queueName.getSimpleName();
    byte[] idWithinFlow = (flowlet + "/" + output).getBytes(Charsets.US_ASCII);

    return getQueueRowPrefix(idWithinFlow);
  }
public static byte [ ] getQueueRowPrefix ( QueueName queueName ) { if ( queueName . isStream ( ) ) { return Bytes . EMPTY_BYTE_ARRAY ; } String flowlet = queueName . getThirdComponent ( ) ; String output = queueName . getSimpleName ( ) ; byte [ ] idWithinFlow = ( flowlet + "/" + output ) . getBytes ( Charsets . US_ASCII ) ; return getQueueRowPrefix ( idWithinFlow ) ; }
Returns a byte array representing prefix of a queue. The prefix is formed by first two bytes of
MD5 of the queue name followed by the queue name.