@Test public void testHasMutationTypeField() { Row rowWith = new RowWithSchema(schemaWithMT, "hello", MutationType.DELETE.toString()); Row rowWithout = PlannerUtils.removeMutationTypeField(rowWith); assertTrue(PlannerUtils.hasMutationTypeField(rowWith)); assertFalse(PlannerUtils.hasMutationTypeField(rowWithout)); }
public static boolean hasMutationTypeField(Row row) { for (String fieldName : row.schema().fieldNames()) { if (fieldName.equals(MutationType.MUTATION_TYPE_FIELD_NAME)) { return true; } } return false; }
PlannerUtils { public static boolean hasMutationTypeField(Row row) { for (String fieldName : row.schema().fieldNames()) { if (fieldName.equals(MutationType.MUTATION_TYPE_FIELD_NAME)) { return true; } } return false; } }
PlannerUtils { public static boolean hasMutationTypeField(Row row) { for (String fieldName : row.schema().fieldNames()) { if (fieldName.equals(MutationType.MUTATION_TYPE_FIELD_NAME)) { return true; } } return false; }  }
PlannerUtils { public static boolean hasMutationTypeField(Row row) { for (String fieldName : row.schema().fieldNames()) { if (fieldName.equals(MutationType.MUTATION_TYPE_FIELD_NAME)) { return true; } } return false; }  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); }
PlannerUtils { public static boolean hasMutationTypeField(Row row) { for (String fieldName : row.schema().fieldNames()) { if (fieldName.equals(MutationType.MUTATION_TYPE_FIELD_NAME)) { return true; } } return false; }  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);  }