public List<FlowEvent> getFlowEvents(FlowKey flowKey) throws IOException {
    byte[] startKey =
        Bytes.add(flowKeyConverter.toBytes(flowKey), Constants.SEP_BYTES);
    Scan scan = new Scan(startKey);
    scan.setFilter(new WhileMatchFilter(new PrefixFilter(startKey)));

    List<FlowEvent> results = new ArrayList<FlowEvent>();
    ResultScanner scanner = null;
    Table eventTable = null;
    try {
      eventTable = hbaseConnection
          .getTable(TableName.valueOf(Constants.FLOW_EVENT_TABLE));
      scanner = eventTable.getScanner(scan);
      for (Result r : scanner) {
        FlowEvent event = createEventFromResult(r);
        if (event != null) {
          results.add(event);
        }
      }
    } finally {
      try {
        if (scanner != null) {
          scanner.close();
        }
      } finally {
        if (eventTable != null) {
          eventTable.close();
        }
      }
    }
    return results;
  }
public List < FlowEvent > getFlowEvents ( FlowKey flowKey ) throws IOException { byte [ ] startKey = Bytes . add ( flowKeyConverter . toBytes ( flowKey ) , Constants . SEP_BYTES ) ; Scan scan = new Scan ( startKey ) ; scan . setFilter ( new WhileMatchFilter ( new PrefixFilter ( startKey ) ) ) ; List < FlowEvent > results = new ArrayList < FlowEvent > ( ) ; ResultScanner scanner = null ; Table eventTable = null ; try { eventTable = hbaseConnection . getTable ( TableName . valueOf ( Constants . FLOW_EVENT_TABLE ) ) ; scanner = eventTable . getScanner ( scan ) ; for ( Result r : scanner ) { FlowEvent event = createEventFromResult ( r ) ; if ( event != null ) { results . add ( event ) ; } } } finally { try { if ( scanner != null ) { scanner . close ( ) ; } } finally { if ( eventTable != null ) { eventTable . close ( ) ; } } } return results ; }
Retrieves all the event rows matching a single
{@link com.twitter.hraven.Flow}.
@param flowKey
@return