[HUDI-2855] Change the default value of 'PAYLOAD_CLASS_NAME' to 'DefaultHoodieRecordPayload' (#4115)
This commit is contained in:
@@ -32,7 +32,7 @@ import org.apache.hudi.common.fs.ConsistencyGuardConfig;
|
|||||||
import org.apache.hudi.common.model.HoodieCleaningPolicy;
|
import org.apache.hudi.common.model.HoodieCleaningPolicy;
|
||||||
import org.apache.hudi.common.model.HoodieFailedWritesCleaningPolicy;
|
import org.apache.hudi.common.model.HoodieFailedWritesCleaningPolicy;
|
||||||
import org.apache.hudi.common.model.HoodieFileFormat;
|
import org.apache.hudi.common.model.HoodieFileFormat;
|
||||||
import org.apache.hudi.common.model.OverwriteWithLatestAvroPayload;
|
import org.apache.hudi.common.model.DefaultHoodieRecordPayload;
|
||||||
import org.apache.hudi.common.model.WriteConcurrencyMode;
|
import org.apache.hudi.common.model.WriteConcurrencyMode;
|
||||||
import org.apache.hudi.common.table.HoodieTableConfig;
|
import org.apache.hudi.common.table.HoodieTableConfig;
|
||||||
import org.apache.hudi.common.table.marker.MarkerType;
|
import org.apache.hudi.common.table.marker.MarkerType;
|
||||||
@@ -102,7 +102,7 @@ public class HoodieWriteConfig extends HoodieConfig {
|
|||||||
|
|
||||||
public static final ConfigProperty<String> WRITE_PAYLOAD_CLASS_NAME = ConfigProperty
|
public static final ConfigProperty<String> WRITE_PAYLOAD_CLASS_NAME = ConfigProperty
|
||||||
.key("hoodie.datasource.write.payload.class")
|
.key("hoodie.datasource.write.payload.class")
|
||||||
.defaultValue(OverwriteWithLatestAvroPayload.class.getName())
|
.defaultValue(DefaultHoodieRecordPayload.class.getName())
|
||||||
.withDocumentation("Payload class used. Override this, if you like to roll your own merge logic, when upserting/inserting. "
|
.withDocumentation("Payload class used. Override this, if you like to roll your own merge logic, when upserting/inserting. "
|
||||||
+ "This will render any value set for PRECOMBINE_FIELD_OPT_VAL in-effective");
|
+ "This will render any value set for PRECOMBINE_FIELD_OPT_VAL in-effective");
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user