in src/main/java/com/microsoft/azure/datalake/store/Core.java [84:121]
public static void create(String path,
boolean overwrite,
String octalPermission,
byte[] contents,
int offsetWithinContentsArray,
int length,
String leaseId,
String sessionId,
boolean createParent,
SyncFlag syncFlag,
ADLStoreClient client,
RequestOptions opts,
OperationResponse resp) {
QueryParams qp = new QueryParams();
qp.add("overwrite", Boolean.toString(overwrite));
qp.add("syncFlag", syncFlag.name());
qp.add("write", "true"); // This is to suppress the 307-redirect from server (standard WebHdfs behavior)
if (leaseId != null && !leaseId.equals("")) {
qp.add("leaseid", leaseId);
}
if (sessionId != null && !sessionId.equals("")) {
qp.add("filesessionid", sessionId);
}
if (!createParent) {
qp.add("CreateParent", "false");
}
if (octalPermission != null && !octalPermission.equals("")) {
if (isValidOctal(octalPermission)) {
qp.add("permission", octalPermission);
} else {
resp.successful = false;
resp.message = "Invalid directory permissions specified: " + octalPermission;
return;
}
}
HttpTransport.makeCall(client, Operation.CREATE, path, qp, contents, offsetWithinContentsArray, length, opts, resp);
}