@Test public void testWrongPartitionPathField() { SimpleKeyGenerator keyGenerator = new SimpleKeyGenerator(getWrongPartitionPathFieldProps()); GenericRecord record = getRecord(); Assertions.assertEquals(keyGenerator.getPartitionPath(record), KeyGenUtils.DEFAULT_PARTITION_PATH); Assertions.assertEquals(keyGenerator.getPartitionPath(KeyGeneratorTestUtilities.getRow(record)), KeyGenUtils.DEFAULT_PARTITION_PATH); }
@Override public String getPartitionPath(GenericRecord record) { return KeyGenUtils.getPartitionPath(record, getPartitionPathFields().get(0), hiveStylePartitioning, encodePartitionPath); }
SimpleKeyGenerator extends BuiltinKeyGenerator { @Override public String getPartitionPath(GenericRecord record) { return KeyGenUtils.getPartitionPath(record, getPartitionPathFields().get(0), hiveStylePartitioning, encodePartitionPath); } }
SimpleKeyGenerator extends BuiltinKeyGenerator { @Override public String getPartitionPath(GenericRecord record) { return KeyGenUtils.getPartitionPath(record, getPartitionPathFields().get(0), hiveStylePartitioning, encodePartitionPath); } SimpleKeyGenerator(TypedProperties props);   SimpleKeyGenerator(TypedProperties props, String partitionPathField);   SimpleKeyGenerator(TypedProperties props, String recordKeyField, String partitionPathField); }
SimpleKeyGenerator extends BuiltinKeyGenerator { @Override public String getPartitionPath(GenericRecord record) { return KeyGenUtils.getPartitionPath(record, getPartitionPathFields().get(0), hiveStylePartitioning, encodePartitionPath); } SimpleKeyGenerator(TypedProperties props);   SimpleKeyGenerator(TypedProperties props, String partitionPathField);   SimpleKeyGenerator(TypedProperties props, String recordKeyField, String partitionPathField); @Override String getRecordKey(GenericRecord record); @Override String getPartitionPath(GenericRecord record); @Override String getRecordKey(Row row); @Override String getPartitionPath(Row row); }
SimpleKeyGenerator extends BuiltinKeyGenerator { @Override public String getPartitionPath(GenericRecord record) { return KeyGenUtils.getPartitionPath(record, getPartitionPathFields().get(0), hiveStylePartitioning, encodePartitionPath); } SimpleKeyGenerator(TypedProperties props);   SimpleKeyGenerator(TypedProperties props, String partitionPathField);   SimpleKeyGenerator(TypedProperties props, String recordKeyField, String partitionPathField); @Override String getRecordKey(GenericRecord record); @Override String getPartitionPath(GenericRecord record); @Override String getRecordKey(Row row); @Override String getPartitionPath(Row row);  }