in src/main/java/com/aliyun/emr/example/hadoop/EMapReduceOSSUtil.java [37:80]
public static String buildOSSCompleteUri(String oriUri, String akId, String akSecret, String endpoint) {
if (akId == null) {
System.err.println("miss accessKeyId");
return oriUri;
}
if (akSecret == null) {
System.err.println("miss accessKeySecret");
return oriUri;
}
if (endpoint == null) {
System.err.println("miss endpoint");
return oriUri;
}
int index = oriUri.indexOf(SCHEMA);
if (index == -1 || index != 0) {
return oriUri;
}
int bucketIndex = index + SCHEMA.length();
int pathIndex = oriUri.indexOf("/", bucketIndex);
String bucket = null;
if (pathIndex == -1) {
bucket = oriUri.substring(bucketIndex);
} else {
bucket = oriUri.substring(bucketIndex, pathIndex);
}
StringBuilder retUri = new StringBuilder();
retUri.append(SCHEMA)
.append(akId)
.append(AKSEP)
.append(akSecret)
.append(BKTSEP)
.append(bucket)
.append(EPSEP)
.append(stripHttp(endpoint));
if (pathIndex > 0) {
retUri.append(oriUri.substring(pathIndex));
}
return retUri.toString();
}