|
Change Parameter Type isApplication : boolean to columnPrefix : ColumnPrefix<?> in method protected readMetrics(entity TimelineEntity, result Result, columnPrefix ColumnPrefix<?>) : void in class org.apache.hadoop.yarn.server.timelineservice.storage.TimelineEntityReader |
From |
To |
|
Change Parameter Type runid : Long to runid : long in method private checkFlowActivityRunId(runid long, flowVersion String, values Map<byte[],byte[]>) : void in class org.apache.hadoop.yarn.server.timelineservice.storage.flow.TestHBaseStorageFlowActivity |
From |
To |
|
Change Parameter Type runid3 : Long to runid3 : long in method private checkFlowActivityTableSeveralRuns(cluster String, user String, flow String, c1 Configuration, flowVersion1 String, runid1 long, flowVersion2 String, runid2 long, flowVersion3 String, runid3 long) : void in class org.apache.hadoop.yarn.server.timelineservice.storage.flow.TestHBaseStorageFlowActivity |
From |
To |
|
Change Parameter Type runid2 : Long to runid2 : long in method private checkFlowActivityTableSeveralRuns(cluster String, user String, flow String, c1 Configuration, flowVersion1 String, runid1 long, flowVersion2 String, runid2 long, flowVersion3 String, runid3 long) : void in class org.apache.hadoop.yarn.server.timelineservice.storage.flow.TestHBaseStorageFlowActivity |
From |
To |
|
Change Parameter Type runid : Long to runid : long in method private checkFlowActivityTable(cluster String, user String, flow String, flowVersion String, runid long, c1 Configuration) : void in class org.apache.hadoop.yarn.server.timelineservice.storage.flow.TestHBaseStorageFlowActivity |
From |
To |
|
Change Parameter Type runid1 : Long to runid1 : long in method private checkFlowActivityTableSeveralRuns(cluster String, user String, flow String, c1 Configuration, flowVersion1 String, runid1 long, flowVersion2 String, runid2 long, flowVersion3 String, runid3 long) : void in class org.apache.hadoop.yarn.server.timelineservice.storage.flow.TestHBaseStorageFlowActivity |
From |
To |
|
Move Method private readMetrics(entity TimelineEntity, result Result, isApplication boolean) : void from class org.apache.hadoop.yarn.server.timelineservice.storage.HBaseTimelineReaderImpl to protected readMetrics(entity TimelineEntity, result Result, columnPrefix ColumnPrefix<?>) : void from class org.apache.hadoop.yarn.server.timelineservice.storage.TimelineEntityReader |
From |
To |
|
Move Method private parseEntity(result Result, fieldsToRetrieve EnumSet<Field>, checkCreatedTime boolean, createdTimeBegin long, createdTimeEnd long, checkModifiedTime boolean, modifiedTimeBegin long, modifiedTimeEnd long, isRelatedTo Map<String,Set<String>>, relatesTo Map<String,Set<String>>, infoFilters Map<String,Object>, configFilters Map<String,String>, eventFilters Set<String>, metricFilters Set<String>, isApplication boolean) : TimelineEntity from class org.apache.hadoop.yarn.server.timelineservice.storage.HBaseTimelineReaderImpl to protected parseEntity(result Result) : TimelineEntity from class org.apache.hadoop.yarn.server.timelineservice.storage.GenericEntityReader |
From |
To |
|
Move Method private readKeyValuePairs(entity TimelineEntity, result Result, prefix ColumnPrefix<T>, isConfig boolean) : void from class org.apache.hadoop.yarn.server.timelineservice.storage.HBaseTimelineReaderImpl to protected readKeyValuePairs(entity TimelineEntity, result Result, prefix ColumnPrefix<T>, isConfig boolean) : void from class org.apache.hadoop.yarn.server.timelineservice.storage.GenericEntityReader |
From |
To |
|
Move Method private validateParams(userId String, clusterId String, appId String, entityType String, entityId String, checkEntityId boolean) : void from class org.apache.hadoop.yarn.server.timelineservice.storage.HBaseTimelineReaderImpl to protected validateParams() : void from class org.apache.hadoop.yarn.server.timelineservice.storage.GenericEntityReader |
From |
To |
|
Move Method private readRelationship(entity TimelineEntity, result Result, prefix ColumnPrefix<T>, isRelatedTo boolean) : void from class org.apache.hadoop.yarn.server.timelineservice.storage.HBaseTimelineReaderImpl to protected readRelationship(entity TimelineEntity, result Result, prefix ColumnPrefix<T>, isRelatedTo boolean) : void from class org.apache.hadoop.yarn.server.timelineservice.storage.GenericEntityReader |
From |
To |
|
Move Method private readEvents(entity TimelineEntity, result Result, isApplication boolean) : void from class org.apache.hadoop.yarn.server.timelineservice.storage.HBaseTimelineReaderImpl to protected readEvents(entity TimelineEntity, result Result, isApplication boolean) : void from class org.apache.hadoop.yarn.server.timelineservice.storage.GenericEntityReader |
From |
To |
|
Move Method private lookupFlowContext(clusterId String, appId String) : FlowContext from class org.apache.hadoop.yarn.server.timelineservice.storage.HBaseTimelineReaderImpl to private lookupFlowContext(clusterId String, appId String, hbaseConf Configuration, conn Connection) : FlowContext from class org.apache.hadoop.yarn.server.timelineservice.storage.GenericEntityReader |
From |
To |
|
Move Attribute private appToFlowTable : AppToFlowTable from class org.apache.hadoop.yarn.server.timelineservice.storage.HBaseTimelineReaderImpl to private appToFlowTable : AppToFlowTable from class org.apache.hadoop.yarn.server.timelineservice.storage.GenericEntityReader |
From |
To |
|
Move Attribute private flowId : String from class org.apache.hadoop.yarn.server.timelineservice.storage.HBaseTimelineReaderImpl.FlowContext to protected flowId : String from class org.apache.hadoop.yarn.server.timelineservice.storage.TimelineEntityReader |
From |
To |
|
Move Attribute private DEFAULT_END_TIME : long from class org.apache.hadoop.yarn.server.timelineservice.storage.HBaseTimelineReaderImpl to private DEFAULT_END_TIME : long from class org.apache.hadoop.yarn.server.timelineservice.storage.GenericEntityReader |
From |
To |
|
Move Attribute private flowRunId : Long from class org.apache.hadoop.yarn.server.timelineservice.storage.HBaseTimelineReaderImpl.FlowContext to protected flowRunId : Long from class org.apache.hadoop.yarn.server.timelineservice.storage.TimelineEntityReader |
From |
To |
|
Move Attribute private DEFAULT_BEGIN_TIME : long from class org.apache.hadoop.yarn.server.timelineservice.storage.HBaseTimelineReaderImpl to private DEFAULT_BEGIN_TIME : long from class org.apache.hadoop.yarn.server.timelineservice.storage.GenericEntityReader |
From |
To |
|
Change Variable Type flow : FlowEntity to flow : FlowRunEntity in method public testPutExtendedEntities() : void in class org.apache.hadoop.yarn.server.timelineservice.TestTimelineServiceClientIntegration |
From |
To |
|
Change Variable Type expmin : Long to minStartTs : long in method public testWriteFlowRunMinMax() : void in class org.apache.hadoop.yarn.server.timelineservice.storage.flow.TestHBaseStorageFlowRun |
From |
To |
|
Change Variable Type cTime : Long to cTime : long in method package getEntityMetricsApp1() : TimelineEntity in class org.apache.hadoop.yarn.server.timelineservice.storage.flow.TestFlowDataGenerator |
From |
To |
|
Change Variable Type mTime : Long to mTime : long in method package getEntity1() : TimelineEntity in class org.apache.hadoop.yarn.server.timelineservice.storage.flow.TestFlowDataGenerator |
From |
To |
|
Change Variable Type runid1 : Long to runid1 : long in method public testFlowActivityTableOneFlowMultipleRunIds() : void in class org.apache.hadoop.yarn.server.timelineservice.storage.flow.TestHBaseStorageFlowActivity |
From |
To |
|
Change Variable Type runid : Long to runid : long in method public testWriteFlowRunMinMax() : void in class org.apache.hadoop.yarn.server.timelineservice.storage.flow.TestHBaseStorageFlowActivity |
From |
To |
|
Change Variable Type cTime : Long to startTs : long in method package getEntityMinStartTime(startTs long) : TimelineEntity in class org.apache.hadoop.yarn.server.timelineservice.storage.flow.TestFlowDataGenerator |
From |
To |
|
Change Variable Type runid : Long to runid : long in method public testWriteFlowRunMetricsOneFlow() : void in class org.apache.hadoop.yarn.server.timelineservice.storage.flow.TestHBaseStorageFlowRun |
From |
To |
|
Change Variable Type runid : Long to runid : long in method public testWriteFlowRunMinMax() : void in class org.apache.hadoop.yarn.server.timelineservice.storage.flow.TestHBaseStorageFlowRun |
From |
To |
|
Change Variable Type runid : Long to runid : long in method public testWriteFlowActivityOneFlow() : void in class org.apache.hadoop.yarn.server.timelineservice.storage.flow.TestHBaseStorageFlowActivity |
From |
To |
|
Change Variable Type cTime : Long to cTime : long in method package getFlowApp1() : TimelineEntity in class org.apache.hadoop.yarn.server.timelineservice.storage.flow.TestFlowDataGenerator |
From |
To |
|
Change Variable Type cTime : Long to cTime : long in method package getEntityMetricsApp2() : TimelineEntity in class org.apache.hadoop.yarn.server.timelineservice.storage.flow.TestFlowDataGenerator |
From |
To |
|
Change Variable Type flow1 : FlowEntity to flow1 : FlowRunEntity in method public testFirstClassCitizenEntities() : void in class org.apache.hadoop.yarn.api.records.timelineservice.TestTimelineServiceRecords |
From |
To |
|
Change Variable Type expTs : Long to expTs : long in method package getEntity1() : TimelineEntity in class org.apache.hadoop.yarn.server.timelineservice.storage.flow.TestFlowDataGenerator |
From |
To |
|
Change Variable Type flow2 : FlowEntity to flow2 : FlowRunEntity in method public testFirstClassCitizenEntities() : void in class org.apache.hadoop.yarn.api.records.timelineservice.TestTimelineServiceRecords |
From |
To |
|
Change Variable Type starttime : Long to starttime : long in method public testWriteFlowRunMinMax() : void in class org.apache.hadoop.yarn.server.timelineservice.storage.flow.TestHBaseStorageFlowRun |
From |
To |
|
Change Variable Type expTs : Long to expTs : long in method package getFlowApp1() : TimelineEntity in class org.apache.hadoop.yarn.server.timelineservice.storage.flow.TestFlowDataGenerator |
From |
To |
|
Change Variable Type cTime : Long to cTime : long in method package getEntity1() : TimelineEntity in class org.apache.hadoop.yarn.server.timelineservice.storage.flow.TestFlowDataGenerator |
From |
To |
|
Extract And Move Method public parseRowKey(rowKey byte[]) : ApplicationRowKey extracted from private isApplicationRowKeyCorrect(rowKey byte[], cluster String, user String, flow String, runid long, appName String) : boolean in class org.apache.hadoop.yarn.server.timelineservice.storage.TestHBaseTimelineStorage & moved to class org.apache.hadoop.yarn.server.timelineservice.storage.application.ApplicationRowKey |
From |
To |
|
Extract And Move Method public parseRowKey(rowKey byte[]) : ApplicationRowKey extracted from private isRowKeyCorrect(rowKey byte[], cluster String, user String, flow String, runid long, appName String, te TimelineEntity) : boolean in class org.apache.hadoop.yarn.server.timelineservice.storage.TestHBaseTimelineStorage & moved to class org.apache.hadoop.yarn.server.timelineservice.storage.application.ApplicationRowKey |
From |
To |