PlannerUtils { public static MutationType getMutationType(Row row) { assertHasMutationTypeField(row); return MutationType.valueOf(row.<String>getAs(MutationType.MUTATION_TYPE_FIELD_NAME)); }  static Row setMutationType(Row row, MutationType mutationType); static MutationType getMutationType(Row row); static Row appendMutationTypeField(Row row); static Row removeMutationTypeField(Row row); static boolean hasMutationTypeField(Row row); static Row copyTime(Row fromRow, TimeModel fromTimeModel, Row into, TimeModel intoTimeModel); static Row copyPrecedingTime(Row fromRow, TimeModel fromTimeModel, Row into, TimeModel intoTimeModel); static boolean before(TimeModel timeModel, Row first, Row second); static boolean simultaneous(TimeModel timeModel, Row first, Row second); static boolean after(TimeModel timeModel, Row first, Row second); static Row appendSurrogateKey(Row row, String fieldName);  }
@Test public void testGetMutationType() { Row row = new RowWithSchema(schemaWithMT, "hello", MutationType.DELETE.toString()); assertEquals(MutationType.DELETE, PlannerUtils.getMutationType(row)); }