@Test
  public void testBasicFilterOperator() throws HiveException {
    VectorFilterOperator vfo = getAVectorFilterOperator();
    prepareVectorFilterOperation(vfo);

    FakeDataReader fdr = new FakeDataReader(1024*1, 3, FakeDataSampleType.Random);

    VectorizedRowBatch vrg = fdr.getNext();

    vfo.getPredicateExpression().evaluate(vrg);

    //Verify
    int rows = 0;
    for (int i =0; i < 1024; i++){
      LongColumnVector l1 = (LongColumnVector) vrg.cols[0];
      LongColumnVector l2 = (LongColumnVector) vrg.cols[1];
      LongColumnVector l3 = (LongColumnVector) vrg.cols[2];
      if ((l1.vector[i] > l2.vector[i]) && (l3.vector[i] == 0)) {
        rows ++;
      }
    }
    Assert.assertEquals(rows, vrg.size);
  }
Test cases for vectorized filter operator.
ql/src/test/org/apache/hadoop/hive/ql/exec/vector/TestVectorFilterOperator.java