Toggle navigation
Home
org.apache.flink.runtime.instance.InstanceID to org.apache.flink.runtime.clusterframework.types.ResourceID
No. of Instances - 24
No. of Commits - 2
No. of Projects - {'flink'}
Hierarchy/Composition: SIBLING
Primitive Info: -
NameSpace: Internal -> Internal
Mapping:
Cascading Type Change (Similar)
Tuple2<InstanceID,String>
to
Tuple2<ResourceID,String>
Collection<Tuple2<InstanceID,String>>
to
Collection<Tuple2<ResourceID,String>>
InstanceID
to
ResourceID
Add or Remove Method invocation
tuple.f0.toString()
to
tuple.f0.getResourceIdString()
StringUtils.hexStringToByte(pathParams.get(TASK_MANAGER_ID_KEY))
to
unescapedString
pathParams.get(TASK_MANAGER_ID_KEY)
to
unescapedString
workerRegistration.getInstanceID()
to
tmResourceId
instances.stream().map((Instance instance) -> { final String taskManagerAddress=instance.getTaskManagerGateway().getAddress(); final String taskManagerMetricQuerServicePath=taskManagerAddress.substring(0,taskManagerAddress.lastIndexOf('/') + 1) + MetricQueryService.METRIC_QUERY_SERVICE_NAME + '_'+ instance.getTaskManagerID().getResourceIdString(); return Tuple2.of(instance.getId(),taskManagerMetricQuerServicePath); } ).collect(Collectors.toList())
to
instances.stream().map((Instance instance) -> { final String taskManagerAddress=instance.getTaskManagerGateway().getAddress(); final String taskManagerMetricQuerServicePath=taskManagerAddress.substring(0,taskManagerAddress.lastIndexOf('/') + 1) + MetricQueryService.METRIC_QUERY_SERVICE_NAME + '_'+ instance.getTaskManagerID().getResourceIdString(); return Tuple2.of(instance.getTaskManagerID(),taskManagerMetricQuerServicePath); } ).collect(Collectors.toList())
Rename Variable
instanceID
to
resourceId
instanceID
to
resourceId
instanceId
to
resourceId
tmID
to
tmRID
instanceID
to
resourceId
instanceID
to
resourceId
instanceId
to
resourceId
instanceId
to
resourceId
instanceId
to
resourceId
instanceId
to
resourceId
instanceId
to
resourceId
instanceId
to
resourceId
getInstanceId
to
getResourceId