@Test public void testWrongRecordKeyField() { GlobalDeleteKeyGenerator keyGenerator = new GlobalDeleteKeyGenerator(getWrongRecordKeyFieldProps()); Assertions.assertThrows(HoodieKeyException.class, () -> keyGenerator.getRecordKey(getRecord())); Assertions.assertThrows(HoodieKeyException.class, () -> keyGenerator.buildFieldPositionMapIfNeeded(KeyGeneratorTestUtilities.structType)); }
@Override public String getRecordKey(GenericRecord record) { return KeyGenUtils.getRecordKey(record, getRecordKeyFields()); }
GlobalDeleteKeyGenerator extends BuiltinKeyGenerator { @Override public String getRecordKey(GenericRecord record) { return KeyGenUtils.getRecordKey(record, getRecordKeyFields()); } }
GlobalDeleteKeyGenerator extends BuiltinKeyGenerator { @Override public String getRecordKey(GenericRecord record) { return KeyGenUtils.getRecordKey(record, getRecordKeyFields()); } GlobalDeleteKeyGenerator(TypedProperties config); }
GlobalDeleteKeyGenerator extends BuiltinKeyGenerator { @Override public String getRecordKey(GenericRecord record) { return KeyGenUtils.getRecordKey(record, getRecordKeyFields()); } GlobalDeleteKeyGenerator(TypedProperties config); @Override String getRecordKey(GenericRecord record); @Override String getPartitionPath(GenericRecord record); @Override List<String> getPartitionPathFields(); @Override String getRecordKey(Row row); @Override String getPartitionPath(Row row); }
GlobalDeleteKeyGenerator extends BuiltinKeyGenerator { @Override public String getRecordKey(GenericRecord record) { return KeyGenUtils.getRecordKey(record, getRecordKeyFields()); } GlobalDeleteKeyGenerator(TypedProperties config); @Override String getRecordKey(GenericRecord record); @Override String getPartitionPath(GenericRecord record); @Override List<String> getPartitionPathFields(); @Override String getRecordKey(Row row); @Override String getPartitionPath(Row row);  }