Skip to content

Commit

Permalink
1
Browse files Browse the repository at this point in the history
  • Loading branch information
@wyxxxcat
wyxxxcat committed Jan 17, 2025
1 parent 3c4a609 commit c312745
Showing 1 changed file with 23 additions and 23 deletions.
46 changes: 23 additions & 23 deletions fe/fe-core/src/main/java/org/apache/doris/binlog/BinlogManager.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -184,7 +184,7 @@ public void addAddPartitionRecord(AddPartitionRecord addPartitionRecord) {
List<Long> tableIds = Lists.newArrayList();
tableIds.add(addPartitionRecord.getTableId());
long commitSeq = addPartitionRecord.getCommitSeq();
long timestamp = -1;
long timestamp = System.currentTimeMillis();
TBinlogType type = TBinlogType.ADD_PARTITION;
String data = addPartitionRecord.toJson();

Expand All @@ -196,7 +196,7 @@ public void addCreateTableRecord(CreateTableRecord createTableRecord) {
List<Long> tableIds = Lists.newArrayList();
tableIds.add(createTableRecord.getTableId());
long commitSeq = createTableRecord.getCommitSeq();
long timestamp = -1;
long timestamp = System.currentTimeMillis();
TBinlogType type = TBinlogType.CREATE_TABLE;
String data = createTableRecord.toJson();

Expand All @@ -207,7 +207,7 @@ public void addDropPartitionRecord(DropPartitionInfo dropPartitionInfo, long com
long dbId = dropPartitionInfo.getDbId();
List<Long> tableIds = Lists.newArrayList();
tableIds.add(dropPartitionInfo.getTableId());
long timestamp = -1;
long timestamp = System.currentTimeMillis();
TBinlogType type = TBinlogType.DROP_PARTITION;
String data = dropPartitionInfo.toJson();

Expand All @@ -219,7 +219,7 @@ public void addDropTableRecord(DropTableRecord record) {
List<Long> tableIds = Lists.newArrayList();
tableIds.add(record.getTableId());
long commitSeq = record.getCommitSeq();
long timestamp = -1;
long timestamp = System.currentTimeMillis();
TBinlogType type = TBinlogType.DROP_TABLE;
String data = record.toJson();

Expand All @@ -230,7 +230,7 @@ public void addAlterJobV2(AlterJobV2 alterJob, long commitSeq) {
long dbId = alterJob.getDbId();
List<Long> tableIds = Lists.newArrayList();
tableIds.add(alterJob.getTableId());
long timestamp = -1;
long timestamp = System.currentTimeMillis();
TBinlogType type = TBinlogType.ALTER_JOB;
AlterJobRecord alterJobRecord = new AlterJobRecord(alterJob);
String data = alterJobRecord.toJson();
Expand All @@ -242,7 +242,7 @@ public void addModifyTableAddOrDropColumns(TableAddOrDropColumnsInfo info, long
long dbId = info.getDbId();
List<Long> tableIds = Lists.newArrayList();
tableIds.add(info.getTableId());
long timestamp = -1;
long timestamp = System.currentTimeMillis();
TBinlogType type = TBinlogType.MODIFY_TABLE_ADD_OR_DROP_COLUMNS;
String data = info.toJson();

Expand All @@ -253,7 +253,7 @@ public void addAlterDatabaseProperty(AlterDatabasePropertyInfo info, long commit
long dbId = info.getDbId();
List<Long> tableIds = Lists.newArrayList();

long timestamp = -1;
long timestamp = System.currentTimeMillis();
TBinlogType type = TBinlogType.ALTER_DATABASE_PROPERTY;
String data = info.toJson();

Expand All @@ -264,7 +264,7 @@ public void addModifyTableProperty(ModifyTablePropertyOperationLog info, long co
long dbId = info.getDbId();
List<Long> tableIds = Lists.newArrayList();
tableIds.add(info.getTableId());
long timestamp = -1;
long timestamp = System.currentTimeMillis();
TBinlogType type = TBinlogType.MODIFY_TABLE_PROPERTY;
String data = info.toJson();

Expand All @@ -285,7 +285,7 @@ public void addBarrierLog(BarrierLog barrierLog, long commitSeq) {

List<Long> tableIds = Lists.newArrayList();
tableIds.add(tableId);
long timestamp = -1;
long timestamp = System.currentTimeMillis();
TBinlogType type = TBinlogType.BARRIER;
String data = barrierLog.toJson();

Expand All @@ -297,7 +297,7 @@ public void addModifyPartitions(BatchModifyPartitionsInfo info, long commitSeq)
long dbId = info.getDbId();
List<Long> tableIds = Lists.newArrayList();
tableIds.add(info.getTableId());
long timestamp = -1;
long timestamp = System.currentTimeMillis();
TBinlogType type = TBinlogType.MODIFY_PARTITIONS;
String data = info.toJson();

Expand All @@ -309,7 +309,7 @@ public void addReplacePartitions(ReplacePartitionOperationLog info, long commitS
long dbId = info.getDbId();
List<Long> tableIds = Lists.newArrayList();
tableIds.add(info.getTblId());
long timestamp = -1;
long timestamp = System.currentTimeMillis();
TBinlogType type = TBinlogType.REPLACE_PARTITIONS;
String data = info.toJson();

Expand All @@ -321,7 +321,7 @@ public void addTruncateTable(TruncateTableInfo info, long commitSeq) {
long dbId = info.getDbId();
List<Long> tableIds = Lists.newArrayList();
tableIds.add(info.getTblId());
long timestamp = -1;
long timestamp = System.currentTimeMillis();
TBinlogType type = TBinlogType.TRUNCATE_TABLE;
TruncateTableRecord record = new TruncateTableRecord(info);
String data = record.toJson();
Expand All @@ -333,7 +333,7 @@ public void addTableRename(TableInfo info, long commitSeq) {
long dbId = info.getDbId();
List<Long> tableIds = Lists.newArrayList();
tableIds.add(info.getTableId());
long timestamp = -1;
long timestamp = System.currentTimeMillis();
TBinlogType type = TBinlogType.RENAME_TABLE;
String data = info.toJson();
addBinlog(dbId, tableIds, commitSeq, timestamp, type, data, false, info);
Expand All @@ -343,7 +343,7 @@ public void addRollupRename(TableInfo info, long commitSeq) {
long dbId = info.getDbId();
List<Long> tableIds = Lists.newArrayList();
tableIds.add(info.getTableId());
long timestamp = -1;
long timestamp = System.currentTimeMillis();
TBinlogType type = TBinlogType.RENAME_ROLLUP;
String data = info.toJson();
addBinlog(dbId, tableIds, commitSeq, timestamp, type, data, false, info);
Expand All @@ -353,7 +353,7 @@ public void addPartitionRename(TableInfo info, long commitSeq) {
long dbId = info.getDbId();
List<Long> tableIds = Lists.newArrayList();
tableIds.add(info.getTableId());
long timestamp = -1;
long timestamp = System.currentTimeMillis();
TBinlogType type = TBinlogType.RENAME_PARTITION;
String data = info.toJson();
addBinlog(dbId, tableIds, commitSeq, timestamp, type, data, false, info);
Expand All @@ -363,7 +363,7 @@ public void addModifyComment(ModifyCommentOperationLog info, long commitSeq) {
long dbId = info.getDbId();
List<Long> tableIds = Lists.newArrayList();
tableIds.add(info.getTblId());
long timestamp = -1;
long timestamp = System.currentTimeMillis();
TBinlogType type = TBinlogType.MODIFY_COMMENT;
String data = info.toJson();

Expand All @@ -374,7 +374,7 @@ public void addColumnRename(TableRenameColumnInfo info, long commitSeq) {
long dbId = info.getDbId();
List<Long> tableIds = Lists.newArrayList();
tableIds.add(info.getTableId());
long timestamp = -1;
long timestamp = System.currentTimeMillis();
TBinlogType type = TBinlogType.RENAME_COLUMN;
String data = info.toJson();

Expand All @@ -386,7 +386,7 @@ public void addModifyViewDef(AlterViewInfo alterViewInfo, long commitSeq) {
long dbId = alterViewInfo.getDbId();
List<Long> tableIds = Lists.newArrayList();
tableIds.add(alterViewInfo.getTableId());
long timestamp = -1;
long timestamp = System.currentTimeMillis();
TBinlogType type = TBinlogType.MODIFY_VIEW_DEF;
String data = alterViewInfo.toJson();

Expand All @@ -402,7 +402,7 @@ public void addReplaceTable(ReplaceTableOperationLog info, long commitSeq) {
long dbId = info.getDbId();
List<Long> tableIds = Lists.newArrayList();
tableIds.add(info.getOrigTblId());
long timestamp = -1;
long timestamp = System.currentTimeMillis();
TBinlogType type = TBinlogType.REPLACE_TABLE;
String data = info.toJson();

Expand All @@ -413,7 +413,7 @@ public void addModifyTableAddOrDropInvertedIndices(TableAddOrDropInvertedIndices
long dbId = info.getDbId();
List<Long> tableIds = Lists.newArrayList();
tableIds.add(info.getTableId());
long timestamp = -1;
long timestamp = System.currentTimeMillis();
TBinlogType type = TBinlogType.MODIFY_TABLE_ADD_OR_DROP_INVERTED_INDICES;
String data = info.toJson();

Expand All @@ -424,7 +424,7 @@ public void addIndexChangeJob(IndexChangeJob indexChangeJob, long commitSeq) {
long dbId = indexChangeJob.getDbId();
List<Long> tableIds = Lists.newArrayList();
tableIds.add(indexChangeJob.getTableId());
long timestamp = -1;
long timestamp = System.currentTimeMillis();
TBinlogType type = TBinlogType.INDEX_CHANGE_JOB;
String data = indexChangeJob.toJson();

Expand All @@ -440,7 +440,7 @@ public void addDropRollup(DropInfo info, long commitSeq) {
long dbId = info.getDbId();
List<Long> tableIds = Lists.newArrayList();
tableIds.add(info.getTableId());
long timestamp = -1;
long timestamp = System.currentTimeMillis();
TBinlogType type = TBinlogType.DROP_ROLLUP;
String data = info.toJson();

Expand All @@ -467,7 +467,7 @@ public void addRecoverTableRecord(RecoverInfo info, long commitSeq) {
long dbId = info.getDbId();
List<Long> tableIds = Lists.newArrayList();
tableIds.add(info.getTableId());
long timestamp = -1;
long timestamp = System.currentTimeMillis();
TBinlogType type = TBinlogType.RECOVER_INFO;
String data = info.toJson();
addBinlog(dbId, tableIds, commitSeq, timestamp, type, data, false, info);
Expand Down

0 comments on commit c312745

Please sign in to comment.