[MINOR] Fix typo, 'upsert' corrected to 'insert' in java write example (#3809)
This commit is contained in:
@@ -96,7 +96,7 @@ public class HoodieJavaWriteClientExample {
|
|||||||
List<HoodieRecord<HoodieAvroPayload>> recordsSoFar = new ArrayList<>(records);
|
List<HoodieRecord<HoodieAvroPayload>> recordsSoFar = new ArrayList<>(records);
|
||||||
List<HoodieRecord<HoodieAvroPayload>> writeRecords =
|
List<HoodieRecord<HoodieAvroPayload>> writeRecords =
|
||||||
recordsSoFar.stream().map(r -> new HoodieRecord<HoodieAvroPayload>(r)).collect(Collectors.toList());
|
recordsSoFar.stream().map(r -> new HoodieRecord<HoodieAvroPayload>(r)).collect(Collectors.toList());
|
||||||
client.upsert(writeRecords, newCommitTime);
|
client.insert(writeRecords, newCommitTime);
|
||||||
|
|
||||||
// updates
|
// updates
|
||||||
newCommitTime = client.startCommit();
|
newCommitTime = client.startCommit();
|
||||||
|
|||||||
Reference in New Issue
Block a user