@Test public void testWrongRecordKeyField() { ComplexKeyGenerator keyGenerator = new ComplexKeyGenerator(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()); }
ComplexKeyGenerator extends BuiltinKeyGenerator { @Override public String getRecordKey(GenericRecord record) { return KeyGenUtils.getRecordKey(record, getRecordKeyFields()); } }
ComplexKeyGenerator extends BuiltinKeyGenerator { @Override public String getRecordKey(GenericRecord record) { return KeyGenUtils.getRecordKey(record, getRecordKeyFields()); } ComplexKeyGenerator(TypedProperties props); }
ComplexKeyGenerator extends BuiltinKeyGenerator { @Override public String getRecordKey(GenericRecord record) { return KeyGenUtils.getRecordKey(record, getRecordKeyFields()); } ComplexKeyGenerator(TypedProperties props); @Override String getRecordKey(GenericRecord record); @Override String getPartitionPath(GenericRecord record); @Override String getRecordKey(Row row); @Override String getPartitionPath(Row row); }
ComplexKeyGenerator extends BuiltinKeyGenerator { @Override public String getRecordKey(GenericRecord record) { return KeyGenUtils.getRecordKey(record, getRecordKeyFields()); } ComplexKeyGenerator(TypedProperties props); @Override String getRecordKey(GenericRecord record); @Override String getPartitionPath(GenericRecord record); @Override String getRecordKey(Row row); @Override String getPartitionPath(Row row); static final String DEFAULT_RECORD_KEY_SEPARATOR; }