Skip to content

Commit

Permalink
rearrange fields
Browse files Browse the repository at this point in the history
  • Loading branch information
gnehil committed Aug 14, 2024
1 parent 4900c12 commit d2c4d0c
Showing 1 changed file with 14 additions and 14 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -128,25 +128,21 @@ public class IngestionLoadJob extends LoadJob {

public static final Logger LOG = LogManager.getLogger(IngestionLoadJob.class);

private long etlStartTimestamp = -1;

private long quorumFinishTimestamp = -1;

private List<Long> loadTableIds = new ArrayList<>();

@Setter
@SerializedName("ests")
private EtlStatus etlStatus;

private final Map<Long, Set<Long>> tableToLoadPartitions = Maps.newHashMap();

private final Map<Long, Map<Long, PushTask>> tabletToSentReplicaPushTask = Maps.newHashMap();

// members below updated when job state changed to loading
// { tableId.partitionId.indexId.bucket.schemaHash -> (etlFilePath, etlFileSize) }
@SerializedName(value = "tm2fi")
private final Map<String, Pair<String, Long>> tabletMetaToFileInfo = Maps.newHashMap();

@SerializedName(value = "hp")
private final Map<String, String> hadoopProperties = new HashMap<>();

@SerializedName(value = "i2sv")
private final Map<Long, Integer> indexToSchemaVersion = new HashMap<>();

private final Map<Long, Integer> indexToSchemaHash = Maps.newHashMap();

private final Map<String, Long> filePathToSize = new HashMap<>();
Expand All @@ -157,11 +153,15 @@ public class IngestionLoadJob extends LoadJob {

private final List<TabletCommitInfo> commitInfos = Lists.newArrayList();

@SerializedName(value = "hp")
private final Map<String, String> hadoopProperties = new HashMap<>();
private final Map<Long, Set<Long>> tableToLoadPartitions = Maps.newHashMap();

@SerializedName(value = "i2sv")
private final Map<Long, Integer> indexToSchemaVersion = new HashMap<>();
private final Map<Long, Map<Long, PushTask>> tabletToSentReplicaPushTask = Maps.newHashMap();

private long etlStartTimestamp = -1;

private long quorumFinishTimestamp = -1;

private List<Long> loadTableIds = new ArrayList<>();

public IngestionLoadJob() {
super(EtlJobType.INGESTION);
Expand Down

0 comments on commit d2c4d0c

Please sign in to comment.