public void Putobject(BosClient client, String BucketName, String ObjectKey, byte[] byte1, String string1){ 
    // Access specified files. 
    File file = new File("/path/to/file.zip"); 
    // Access data stream. 
    InputStream inputStream = new FileInputStream("/path/to/test.zip"); 
	
    // Upload object as file. 
    PutObjectResponse putObjectFromFileResponse = client.putObject(BucketName, ObjectKey, file); 
    // Upload object as the data stream. 
    PutObjectResponse putObjectResponseFromInputStream = client.putObject(BucketName, ObjectKey, inputStream); 
    // Upload object as the binary string. 
    PutObjectResponse putObjectResponseFromByte = client.putObject(BucketName, ObjectKey, byte1); 
    // Upload object as the character string. 
    PutObjectResponse putObjectResponseFromString = client.putObject(BucketName, ObjectKey, string1); 
	
    // Print ETag. 
    System.out.println(putObjectFromFileResponse.getETag()); 
} 

// Upload input stream in initialization 
ObjectMetadata meta = new ObjectMetadata(); 

// Set the size of ContentLength. 
meta.setContentLength(1000); 

// Set ContentType. 
meta.setContentType("application/json"); 

// Set cache-control. 
meta.setCacheControl("no-cache"); 

// Set x-bce-content-crc32 
meta.setxBceCrc("crc"); 

client.putObject(BucketName, ObjectKey, content, meta); 

// Set the name value of customized metadata as my-data. 
meta.addUserMetadata("name", "my-data"); 
    
// object uploading 
client.putObject(BucketName, ObjectKey, content, meta); 

public void putObjectStorageClass(){ 
    PutObjectRequest request = new PutObjectRequest(BucketName, key, file); 
    request.withStorageClass(BosClient.STORAGE_CLASS_STANDARD_IA); 
    client.putObject(request); 
} 

public void appendObject(BosClient client, String BucketName, String ObjectKey, byte[] byte1, String string1) { 
        // Access specified files. 
        File file = new File("/path/to/file.zip"); 
        // Access data stream. 
        InputStream inputStream = new FileInputStream("/path/to/test.zip"); 

        // Upload object as file. 
        AppendObjectResponse appendobjectFromFileResponse = client.appendobject(BucketName, ObjectKey, file); 
        // Upload object as the data stream. 
        AppendObjectResponse appendObjectResponseFromInputStream = client.appendobject(BucketName, ObjectKey, inputStream); 
        // Upload object as the binary string. 
        AppendObjectResponse appendObjectResponseFromByte = client.appendobject(BucketName, ObjectKey, byte1); 
        // Upload object as the character string. 
        AppendObjectResponse appendObjectResponseFromString = client.appendobject(BucketName, ObjectKey, string1); 

        // Print ETag. 
        System.out.println(appendobjectFromFileResponse.getETag()); 
        // Print NextAppendOffset. 
        System.out.println(appendobjectFromFileResponse.getNextAppendOffset()); 
        // Print ContentMd5.
        System.out.println(appendobjectFromFileResponse.getContentMd5()); 

        // For an example of appended upload, you need to add the location of the next append in the request. 
        Long nextAppendOffset = appendobjectFromFileResponse.getNextAppendOffset(); 
        AppendObjectRequest appendobjectFromFileRequest = new AppendObjectRequest(BucketName,ObjectKey,file); 
        appendObjectFromFileRequest.setOffset(nextAppendOffset);
        AppendObjectResponse appendobjectFromFileResponse = client.appendobject(appendobjectFromFileRequest); 
    } 

// Start Multipart Upload. 
InitiateMultipartUploadRequest initiateMultipartUploadRequest = 
        new InitiateMultipartUploadRequest(BucketName, ObjectKey); 
InitiateMultipartUploadResponse initiateMultipartUploadResponse = 
        client.initiateMultipartUpload(initiateMultipartUploadRequest); 
    
// Print UploadId. 
System.out.println("UploadId: " + initiateMultipartUploadResponse.getUploadId()); 

public void putMultiUploadStorageClass(){ 
    InitiateMultipartUploadRequest iniReq = new InitiateMultipartUploadRequest(BucketName, key); 
    iniReq.withStorageClass(BosClient.STORAGE_CLASS_STANDARD_IA); 
    client.initiateMultipartUpload(iniReq); 
} 

public void putMultiUploadStorageClass(){ 
    InitiateMultipartUploadRequest iniReq = new InitiateMultipartUploadRequest(BucketName, key); 
    iniReq.withStorageClass(BosClient.STORAGE_CLASS_COLD); 
    client.initiateMultipartUpload(iniReq); 
} 

// Set each part to 5 MB. 
final long partSize = 1024 * 1024 * 5L; 
    
File partFile = new File("/path/to/file.zip"); 
    
// Calculate the number of part. 
int partCount = (int) (partFile.length() / partSize); 
if (partFile.length() % partSize != 0){ 
    partCount++; 
} 
    
// Create a List to save the ETag and PartNumber uploaded in parts. 
List<PartETag> partETags = new ArrayList<PartETag>(); 
    
for(int i = 0; i< partCount; i++){ 
    // Get file stream. 
    FileInputStream fis = new FileInputStream(partFile); 
    
    // Skip to the beginning of each part. 
    long skipBytes = partSize * i; 
    fis.skip(skipBytes); 
    
    // Calculate the size of each part. 
    long size = partSize< partFile.length() - skipBytes ? 
            partSize : partFile.length() - skipBytes; 
    
    // Create UploadPartRequest, and upload part. 
    UploadPartRequest uploadPartRequest = new UploadPartRequest(); 
    uploadPartRequest.setBucketName(BucketName); 
    uploadPartRequest.setKey(ObjectKey); 
    uploadPartRequest.setUploadId(initiateMultipartUploadResponse.getUploadId()); 
    uploadPartRequest.setInputStream(fis); 
    uploadPartRequest.setPartSize(size); 
    uploadPartRequest.setPartNumber(i + 1); 
    UploadPartResponse uploadPartResponse = client.uploadPart(uploadPartRequest); 
    
    // Save the returned PartETag to the List. 
    partETags.add(uploadPartResponse.getPartETag()); 
   
    // Close the file. 
    fis.close(); 
} 

CompleteMultipartUploadRequest completeMultipartUploadRequest = 
        new CompleteMultipartUploadRequest(BucketName, ObjectKey, initiateMultipartUploadResponse.getUploadId(), partETags); 
    
// Complete Multipart Upload. 
CompleteMultipartUploadResponse completeMultipartUploadResponse = 
        client.completeMultipartUpload(completeMultipartUploadRequest); 
    
// Print the ETag of object. 
System.out.println(completeMultipartUploadResponse.getETag()); 

AbortMultipartUploadRequest abortMultipartUploadRequest = 
        new AbortMultipartUploadRequest(BucketName, ObjectKey, uploadId); 
    
// Cancel Multipart Upload. 
client.abortMultipartUpload(abortMultipartUploadRequest); 

ListMultipartUploadsRequest listMultipartUploadsRequest = 
    new ListMultipartUploadsRequest(BucketName); 

// Get all upload events in the bucket. 
ListMultipartUploadsResponse listing = client.listMultipartUploads(listMultipartUploadsRequest); 
    
// Traverse all uploaded events. 
for (MultipartUploadSummary multipartUpload : listing.getMultipartUploads()) { 
    System.out.println("Key: " + multipartUpload.getKey() + " UploadId: " + multipartUpload.getUploadId()); 
} 

ListPartsRequest listPartsRequest = new ListPartsRequest(BucketName, ObjectKey, uploadId); 
    
// Get information about all uploaded Parts. 
ListPartsResponse partListing = client.listParts(listPartsRequest); 
    
// Traverse all Parts. 
for (PartSummary part : partListing.getParts()) { 
    System.out.println("PartNumber: " + part.getPartNumber() + " ETag: " + part.getETag()); 
} 

public void listPartsStorageClass(){ 
    ListResponse listPartsResponse = client.listParts(BucketName, key, uploadId); 
    String storageClass = listPartsResponse.getStorageClass(); 
} 

File file = new File("/path/to/file.zip"); 
PutSuperObjectRequest request = new PutSuperObjectRequest(BucketName, ObjectKey, file); 
bosClient.putSuperobjectFromFile(request); 

public void getobject(BosClient client, String BucketName, String ObjectKey) 
    throws IOException { 

    // Get object and return BosObject. 
    BosObject object = client.getobject(BucketName, ObjectKey); 

    // Get objectMeta. 
    ObjectMetadata meta = object.getObjectMetadata(); 

    // Get the input stream of object. 
    InputStream ObjectContent = object.getObjectContent(); 

    // Process object. 
    ...

    // Close stream. 
    ObjectContent.close(); 
} 

// Create a GetObjectRequest. 
GetObjectRequest getObjectRequest = new GetObjectRequest(BucketName, ObjectKey); 
    
// Download object to file. 
ObjectMetadata ObjectMetadata = client.getobject(getObjectRequest, new File("/path/to/file","filename")); 

// Create a GetObjectRequest. 
GetObjectRequest getObjectRequest = new GetObjectRequest(BucketName, ObjectKey); 

// Get data in the range of 0-100 bytes. 
getObjectRequest.setRange(0, 100); 

// Get object and return BosObject. 
BosObject object = client.getobject(getObjectRequest); 

public void getObjectStorageClass(){ 
    ObjectMetadata meta = client.getObjectMetadata(BucketName, key); 
    String storageClass = meta.getStorageClass(); 
} 

ObjectMetadata ObjectMetadata = client.getObjectMetadata(BucketName, ObjectKey); 

// Standard storage to infrequency storage 
CopyObjectRequest copyObjectRequest = new CopyObjectRequest(srcBucketName, srcKey, destBucketName, destKey); 
copyObjectRequest.setStorageClass("STANDARD_IA"); 
client.copyobject(copyObjectRequest); 

// infrequency storage to cold storage 
CopyObjectRequest copyObjectRequest = new CopyObjectRequest(srcBucketName, srcKey, destBucketName, destKey); 
copyObjectRequest.setStorageClass("COLD"); 
client.copyobject(copyObjectRequest); 

public String generatePresignedUrl(BosClient client, String BucketName, String ObjectKey, int expirationInSeconds) { 

   URL url = client.generatePresignedUrl(BucketName,<ObjectKey,<expirationInSeconds>); 
   //Specify name of bucket of object which users need to obtain, name of that object, time stamp and effective duration of URL   

    return url.toString(); 
} 

public void listobjects(BosClient client, String BucketName) { 

    // Access all object information of specified bucket. 
    ListobjectsResponse listing = client.listobjects(BucketName); 

    // Traverse all objects. 
    for (BosObjectSummary objectSummary : listing.getContents()) { 
        System.out.println("ObjectKey: " + objectSummary.getKey()); 
    } 

} 

// Specify the maximum number of returned entries to be 500. 
ListobjectsRequest listobjectsRequest = new ListobjectsRequest("BucketName"); 
listobjectsRequest.withMaxKeys(500); 
ListobjectsResponse listobjectsResponse = client.listobjects(listobjectsRequest); 
for(BosObjectSummary objectSummary :listobjectsResponse.getContents()) { 
    System.out.println("ObjectKey:" + objectSummary.getKey()); 
} 

// Specify the returned object with test as the prefix. 
ListobjectsRequest listobjectsRequest = new ListobjectsRequest("BucketName"); 
listobjectsRequest.withPrefix("test"); 
ListobjectsResponse listobjectsResponse = client.listobjects(listobjectsRequest); 
for(BosObjectSummary objectSummary :listobjectsResponse.getContents()) { 
    System.out.println("ObjectKey:" + objectSummary.getKey()); 
} 

// You can define an object not to be included, and return from it. 
ListobjectsRequest listobjectsRequest = new ListobjectsRequest("BucketName"); 
listobjectsRequest.withMarker("object"); 
ListobjectsResponse listobjectsResponse = client.listobjects(listobjectsRequest); 
for(BosObjectSummary objectSummary :listobjectsResponse.getContents()) { 
    System.out.println("ObjectKey:" + objectSummary.getKey()); 
} 

// You can set a maximum of 500 records per page. 
ListobjectsRequest listobjectsRequest = new ListobjectsRequest("BucketName"); 
listobjectsRequest.withMaxKeys(500); 
ListobjectsResponse listobjectsResponse; 
boolean isTruncated = true; 
while (isTruncated) { 
    listobjectsResponse = client.listobjects(listobjectsRequest); 
    isTruncated = listobjectsResponse.isTruncated(); 
    if (listobjectsResponse.getNextMarker() != null) { 
        listobjectsRequest.withMarker(listobjectsResponse.getNextMarker()); 
    } 
} 

// You can set up to 500 records per page and get them from a specific object. 
ListobjectsRequest listobjectsRequest = new ListobjectsRequest("BucketName"); 
listobjectsRequest.withMaxKeys(500); 
listobjectsRequest.withMarker("object"); 
ListobjectsResponse listobjectsResponse; 
boolean isTruncated = true; 
while (isTruncated) { 
    listobjectsResponse = client.listobjects(listobjectsRequest); 
    isTruncated = listobjectsResponse.isTruncated(); 
    if (listobjectsResponse.getNextMarker() != null) { 
        listobjectsRequest.withMarker(listobjectsResponse.getNextMarker()); 
    } 
} 

// You can set the page to get the object with the specified prefix, with a maximum of 500 records per page. 
ListobjectsRequest listobjectsRequest = new ListobjectsRequest("BucketName"); 
listobjectsRequest.withMaxKeys(500); 
listobjectsRequest.withPrefix("object"); 
ListobjectsResponse listobjectsResponse; 
boolean isTruncated = true; 
while (isTruncated) { 
    listobjectsResponse = client.listobjects(listobjectsRequest); 
    isTruncated = listobjectsResponse.isTruncated(); 
    if (listobjectsResponse.getNextMarker() != null) { 
        listobjectsRequest.withMarker(listobjectsResponse.getNextMarker()); 
    } 
} 

// Create the request of ListobjectsRequest. 
ListobjectsRequest listobjectsRequest = new ListobjectsRequest(BucketName); 
    
// Recursively list all files in the fun directory. 
listobjectsRequest.setPrefix("fun/"); 
    
ListobjectsResponse listing = client.listobjects(listobjectsRequest); 
    
// Traverse all objects. 
System.out.println("objects:"); 
for (BosObjectSummary objectSummary : listing.getContents()) { 
    System.out.println(objectSummary.getKey()); 
	 } 
} 

objects: 
fun/ 
fun/movie/001.avi 
fun/movie/007.avi 
fun/test.jpg 

// Create the request of ListobjectsRequest. 
ListobjectsRequest listobjectsRequest = new ListobjectsRequest(BucketName); 
    
// '/' is a folder separator. 
listobjectsRequest.setDelimiter("/"); 
    
// List all files and folders under fun file directory. 
listobjectsRequest.setPrefix("fun/"); 
    
ListobjectsResponse listing = client.listobjects(listobjectsRequest); 
    
// Traverse all objects. 
System.out.println("objects:"); 
for (BosObjectSummary objectSummary : listing.getContents()) { 
    System.out.println(objectSummary.getKey()); 
} 
    
// Traverse all CommonPrefix. 
System.out.println("\nCommonPrefixs:"); 
for (String commonPrefix : listing.getCommonPrefixes()) { 
    System.out.println(commonPrefix); 
} 

objects: 
fun/ 
fun/test.jpg 

CommonPrefixs: 
fun/movie/

public void listobjectsStorageClass(){ 
    ListobjectsResponse listObjectResponse = client.listobjects("BucketName"); 
    List<BosObjectSummary> objectList = listObjectResponse.getContents(); 
    for(int i=0; i<objectList.length(); i++) { 
        System.out.println(objectList[i].getStorageClass()); 
    } 
} 

SetObjectAclRequest setObjectAclRequest = new SetObjectAclRequest("yourBucketName","ObjectKey",CannedAccessControlList.PublicRead); 
client.setObjectAcl(setObjectAclRequest); 

String xBceGrantRead = "id=\"user_id1\""+",id=\"user_id2\""; 
SetObjectAclRequest setObjectAclRequest = new SetObjectAclRequest(); 
setObjectAclRequest.withBucketName("yourBucketName"); 
setObjectAclRequest.withKey("ObjectKey"); 
setObjectAclRequest.setxBceGrantRead(xBceGrantRead); 
client.setObjectAcl(setObjectAclRequest); 

String xBceGrantFullControl = "id=\"user_id1\""+",id=\"user_id2\""; 
SetObjectAclRequest setObjectAclRequest = new SetObjectAclRequest(); 
setObjectAclRequest.withBucketName("yourBucketName"); 
setObjectAclRequest.withKey("ObjectKey"); 
setObjectAclRequest.setxBceGrantFullControl(xBceGrantFullControl); 
client.setObjectAcl(setObjectAclRequest); 

String jsonObjectAcl = "{\"accessControlList\":["+ "{\"grantee\":[{\"id\":\"*\"}], "+ "\"privilege\":[\"FULL_CONTROL\"]"+"}]}"; 

SetObjectAclRequest setObjectAclRequest = new SetObjectAclRequest("yourBucketName","ObjectKey",jsonObjectAcl); 

client.setObjectAcl(setObjectAclRequest); 

List<Grant> grants = new ArrayList<Grant>(); 
List<Grantee> grantees = new ArrayList<Grantee>(); 
List<privilege> privileges = new ArrayList<privilege>(); 

// privilege to specific users 
grantees.add(new Grantee("user_id1")); 
grantees.add(new Grantee("user_id2")); 
grantees.add(new Grantee("user_id3")); 

// privilege setting 
privileges.add(privilege.READ); 
grants.add(new Grant().withGrantee(grantees).withprivilege(privileges)); 

SetObjectAclRequest setObjectAclRequest = new SetObjectAclRequest("yourBucketName","ObjectKey", grants); 
client.setObjectAcl(setObjectAclRequest); 

GetObjectAclRequest getObjectRequest = new GetObjectAclRequest(); 
getObjectRequest.withBucketName("yourBucketName"); 
getObjectRequest.withKey("ObjectKey"); 
GetObjectAclResponse response = client.getObjectAcl(getObjectRequest); 

DeleteObjectAclRequest deleteObjectAclRequest = new DeleteObjectAclRequest("yourBucketName","ObjectKey"); 

client.deleteObjectAcl(deleteObjectAclRequest); 

public void deleteobject(BosClient client, String BucketName, String ObjectKey) { 

    // Delete object. 
    client.deleteobject(BucketName,<ObjectKey);           //Specify the bucket name of the object to be deleted and the object name. 
} 

// 1.String in Json format 
String jsonObjectKeys = "{\"objects\": ["+"{\"key\": \"token1.h\"},"+"{\"key\": \"token2.h\"}"+"]}"; 
DeleteMultipleobjectsRequest request = new DeleteMultipleobjectsRequest(); 
request.setBucketName("yourBucketName"); 
request.setJsonDeleteobjects(jsonObjectKeys); 
client.deleteMultipleobjects(request); 

// 2.Users only need to specify the specified parameters 
List<String> ObjectKeys = new ArrayList<String>(); 
ObjectKeys.add("object1"); 
ObjectKeys.add("object2"); 
DeleteMultipleobjectsRequest request = new DeleteMultipleobjectsRequest(); 
request.setBucketName("yourBucketName"); 
request.setObjectKeys(ObjectKeys); 
DeleteMultipleobjectsResponse response = client.deleteMultipleobjects(request); 

// If true is returned, but false is not, other exceptions are thrown. 
bool exists = client.doesobjectExist("BucketName", "ObjectKey"); 

  public void setobjectMeta(BosClient client, String BucketName, String ObjectKey, ObjectMetadata newObjectMetadata) { 
        
        CopyObjectRequest request = new CopyObjectRequest(BucketName, ObjectKey, BucketName, ObjectKey); 

        // Create ObjectMetadata. 
        request.setNewObjectMetadata(newObjectMetadata); 

        // Copy object. 
        CopyObjectResponse copyObjectResponse = client.copyobject(request); 

        // Print results. 
        System.out.println("ETag: " + copyObjectResponse.getETag() + " LastModified: " + copyObjectResponse.getLastModified()); 
    } 

public void copyobject(BosClient client, String srcBucketName, String srcKey, String destBucketName, String destKey) { 
    
    // Copy object. 
    CopyObjectResponse copyObjectResponse = client.copyobject(srcBucketName, srcKey, destBucketName, destKey); 
    
    // Print results. 
    System.out.println("ETag: " + copyObjectResponse.getETag() + " LastModified: " + copyObjectResponse.getLastModified()); 
} 

// Initialize BosClient. 
BosClient client = ...; 
    
// Create CopyObjectRequest. 
CopyObjectRequest copyObjectRequest = new CopyObjectRequest(srcBucketName, srcKey, destBucketName, destKey); 
    
// Create Metadata. 
Map<String, String> userMetadata = new HashMap<String, String>(); 
userMetadata.put('<user-meta-key>','<user-meta-value>'); 
ObjectMetadata meta = new ObjectMetadata();
meta.setUserMetadata(userMetadata); 
copyObjectRequest.setNewObjectMetadata(meta); 
    
// Copy object. 
CopyObjectResponse copyObjectResponse = client.copyobject(copyObjectRequest); 
    
System.out.println("ETag: " + copyObjectResponse.getETag() + " LastModified: " + copyObjectResponse.getLastModified()); 

// Initialize BosClient
BosClient client = ...;
// Create CopyObjectRequest
CopyObjectRequest copyObjectRequest = new CopyObjectRequest(srcBucketName, srcKey, destBucketName, destKey);
// Create Metadata
Map<String, String> userMetadata = new HashMap<String, String>();
userMetadata.put("<user-meta-key>","<user-meta-value>");
        
meta.setUserMetadata(userMetadata);
copyObjectRequest.setNewObjectMetadata(meta);
//copy-source-if-match
copyObjectRequest.withETag("111111111183bf192b57a4afc76fa632");
//copy-source-if-none-match
copyObjectRequest.withNoMatchingETagConstraint("111111111183bf192b57a4afc76fa632");
        
Date modifiedSinceConstraint = new Date();    
SimpleDateFormat df = new SimpleDateFormat("E, dd MMM yyyy HH:mm:ss z", Locale.UK);  
df.setTimeZone(new java.util.SimpleTimeZone(0, "GMT"));        
String date = df.format(modifiedSinceConstraint);
//copy-source-if-modified-since
copyObjectRequest.withModifiedSinceConstraint(date);
//copy-source-if-unmodified-since
copyObjectRequest.withUnmodifiedSinceConstraint(date);
CopyObjectResponse copyObjectResponse = client.copyObject(copyObjectRequest);
System.out.println("ETag: " + copyObjectResponse.getETag() + " LastModified: " + copyObjectResponse.getLastModified());

// Step 1: init 
InitiateMultipartUploadRequest initiateMultipartUploadRequest = 
        new InitiateMultipartUploadRequest("targetBucketName","targetObjectName"); 
InitiateMultipartUploadResponse initiateMultipartUploadResponse = 
        client.initiateMultipartUpload(initiateMultipartUploadRequest); 

// Step 2: Multipart Upload Copy 
long left_size=client.getObjectMetadata("sourceBucketName","sourceObjectName").getContentLength(); 
long skipBytes = 0; 
int partNumber = 1; 
List<PartETag> partETags = new ArrayList<PartETag>(); 

while (left_size > 0) { 
    long partSize = 1024 * 1024 * 1L; 
    if (left_size< partSize) { 
        partSize = left_size; 
    } 
    UploadPartCopyRequest uploadPartCopyRequest = new UploadPartCopyRequest(); 
    uploadPartCopyRequest.setBucketName("targetBucketName"); 
    uploadPartCopyRequest.setKey("targetObjectName"); 
    uploadPartCopyRequest.setSourceBucketName("sourceBucketName"); 
    uploadPartCopyRequest.setSourceKey("sourceObjectName"); 
    uploadPartCopyRequest.setUploadId(initiateMultipartUploadResponse.getUploadId()); 
    uploadPartCopyRequest.setPartSize(partSize); 
    uploadPartCopyRequest.setOffSet(skipBytes); 
    uploadPartCopyRequest.setPartNumber(partNumber); 
    UploadPartCopyResponse uploadPartCopyResponse = client.uploadPartCopy(uploadPartCopyRequest); 
    // Save the PartETag returned to List. 
    PartETag partETag = new PartETag(partNumber,uploadPartCopyResponse.getETag()); 
    partETags.add(partETag); 
    left_size -= partSize; 
    skipBytes += partSize; 
    partNumber+=1; 
} 

// Step 3: complete 
CompleteMultipartUploadRequest completeMultipartUploadRequest = 
        new CompleteMultipartUploadRequest("targetBucketName", "targetObjectName", initiateMultipartUploadResponse.getUploadId(), partETags); 
CompleteMultipartUploadResponse completeMultipartUploadResponse = 
        client.completeMultipartUpload(completeMultipartUploadRequest); 

final String csvContent = "header1,header2,header3\r\n" +
                          "1,2,3.4\r\n" +
                          "a,b,c\r\n" +
                          "\"d\",\"e\",\"f\"\r\n" +
                          "true,false,true\r\n" +
                          "2006-01-02 15:04:06,2006-01-02 16:04:06,2006-01-02 17:04:06";
client.putObject("bucketName", "test-csv", new ByteArrayInputStream(csvContent.getBytes()));
SelectObjectRequest request = new SelectObjectRequest("bucketName", "test-csv")
        .withSelectType("csv")                                   
        .withExpression("select * from BosObject limit 3")
        .withInputSerialization(new InputSerialization()
                .withCompressionType("NONE")
                .withFileHeaderInfo("NONE")
                .withRecordDelimiter("\r\n")
                .withFieldDelimiter(",")
                .withQuoteCharacter("\"")
                .withCommentCharacter("#"))
        .withOutputSerialization(new OutputSerialization()
                .withOutputHeader(false)
                .withQuoteFields("ALWAYS")
                .withRecordDelimiter("\n")
                .withFieldDelimiter(",")
                .withQuoteCharacter("\""))
        .withRequestProgress(false);
SelectObjectResponse response = client.selectObject(request);
// Output the returned records 
SelectObjectResponse.Messages messages = response.getMessages();
while (messages.hasNext()) {
    SelectObjectResponse.CommonMessage message = messages.next();
    if (message.Type.equals("Records")) {
        for (String record: message.getRecords()) {
            System.out.println(record);
        }
    }
}

"header1","header2","header3"
"1","2","3.4"
"a","b","c"

final String jsonContent = "{\n" +
        "\t\"name\": \"Smith\",\n" +
        "\t\"age\": 16,\n" +
        "\t\"org\": null\n" +
        "}\n" +
        "{\n" +
        "\t\"name\": \"charles\",\n" +
        "\t\"age\": 27,\n" +
        "\t\"org\": \"baidu\"\n" +
        "}\n" +
        "{\n" +
        "\t\"name\": \"jack\",\n" +
        "\t\"age\": 35,\n" +
        "\t\"org\": \"bos\"\n" +
        "}";
client.putObject("bucketName", "test-json", new ByteArrayInputStream(jsonContent.getBytes()));
SelectObjectRequest request = new SelectObjectRequest("bucketName", "test-json")
        .withSelectType("json")
        .withExpression("select * from BosObject where age > 20")
        .withInputSerialization(new InputSerialization()
                .withCompressionType("NONE")
                .withJsonType("LINES"))
        .withOutputSerialization(new OutputSerialization()
                .withRecordDelimiter("\n"))
        .withRequestProgress(false);
SelectObjectResponse response = client.selectObject(request);
// Output the returned records 
SelectObjectResponse.Messages messages = response.getMessages();
while (messages.hasNext()) {
    SelectObjectResponse.CommonMessage message = messages.next();
    if (message.Type.equals("Records")) {
        for (String record: message.getRecords()) {
            System.out.println(record);
        }
    }
}

{"name":"charles","age":27,"org":"baidu"}
{"name":"jack","age":35,"org":"bos"}