1final String csvContent = "header1,header2,header3\r\n" +
2                          "1,2,3.4\r\n" +
3                          "a,b,c\r\n" +
4                          "\"d\",\"e\",\"f\"\r\n" +
5                          "true,false,true\r\n" +
6                          "2025-08-05 15:04:06,2025-08-05 16:04:06,2025-08-05 17:04:06";
7client.putObject("bucketName", "test-csv", new ByteArrayInputStream(csvContent.getBytes()));
8
9SelectObjectRequest request = new SelectObjectRequest("bucketName", "test-csv")
10        .withSelectType("csv")                                   
11        .withExpression("select * from BosObject limit 3")
12        .withInputSerialization(new InputSerialization()
13                .withCompressionType("NONE")
14                .withFileHeaderInfo("NONE")
15                .withRecordDelimiter("\r\n")
16                .withFieldDelimiter(",")
17                .withQuoteCharacter("\"")
18                .withCommentCharacter("#"))
19        .withOutputSerialization(new OutputSerialization()
20                .withOutputHeader(false)
21                .withQuoteFields("ALWAYS")
22                .withRecordDelimiter("\n")
23                .withFieldDelimiter(",")
24                .withQuoteCharacter("\""))
25        .withRequestProgress(false);
26SelectObjectResponse response = client.selectObject(request);
27
28// 输出返回的记录
29SelectObjectResponse.Messages messages = response.getMessages();
30while (messages.hasNext()) {
31    SelectObjectResponse.CommonMessage message = messages.next();
32    if (message.Type.equals("Records")) {
33        for (String record: message.getRecords()) {
34            System.out.println(record);
35        }
36    }
37}

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

1final String jsonContent = "{\n" +
2        "\t\"name\": \"Smith\",\n" +
3        "\t\"age\": 16,\n" +
4        "\t\"org\": null\n" +
5        "}\n" +
6        "{\n" +
7        "\t\"name\": \"charles\",\n" +
8        "\t\"age\": 27,\n" +
9        "\t\"org\": \"baidu\"\n" +
10        "}\n" +
11        "{\n" +
12        "\t\"name\": \"jack\",\n" +
13        "\t\"age\": 35,\n" +
14        "\t\"org\": \"bos\"\n" +
15        "}";
16client.putObject("bucketName", "test-json", new ByteArrayInputStream(jsonContent.getBytes()));
17
18SelectObjectRequest request = new SelectObjectRequest("bucketName", "test-json")
19        .withSelectType("json")
20        .withExpression("select * from BosObject where age > 20")
21        .withInputSerialization(new InputSerialization()
22                .withCompressionType("NONE")
23                .withJsonType("LINES"))
24        .withOutputSerialization(new OutputSerialization()
25                .withRecordDelimiter("\n"))
26        .withRequestProgress(false);
27SelectObjectResponse response = client.selectObject(request);
28
29// 输出返回的记录
30SelectObjectResponse.Messages messages = response.getMessages();
31while (messages.hasNext()) {
32    SelectObjectResponse.CommonMessage message = messages.next();
33    if (message.Type.equals("Records")) {
34        for (String record: message.getRecords()) {
35            System.out.println(record);
36        }
37    }
38}

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

1/*
2parquet文件解析内容
3{"Name":"StudentName","Age":20,"Id":0,"Weight":50,"Sex":true,"Day":19240,"Scores":{"computer":80,"math":90,"physics":90}}
4{"Name":"StudentName","Age":21,"Id":1,"Weight":50.1,"Sex":false,"Day":19240,"Scores":{"computer":81,"math":91,"physics":91}}
5{"Name":"StudentName","Age":22,"Id":2,"Weight":50.2,"Sex":true,"Day":19240,"Scores":{"computer":82,"math":92,"physics":92}}
6{"Name":"StudentName","Age":23,"Id":3,"Weight":50.3,"Sex":false,"Day":19240,"Scores":{"computer":83,"math":93,"physics":90}}
7{"Name":"StudentName","Age":24,"Id":4,"Weight":50.4,"Sex":true,"Day":19240,"Scores":{"computer":84,"math":94,"physics":91}}
8{"Name":"StudentName","Age":20,"Id":5,"Weight":50.5,"Sex":false,"Day":19240,"Scores":{"computer":85,"math":90,"physics":92}}
9{"Name":"StudentName","Age":21,"Id":6,"Weight":50.6,"Sex":true,"Day":19240,"Scores":{"computer":86,"math":91,"physics":90}}
10{"Name":"StudentName","Age":22,"Id":7,"Weight":50.7,"Sex":false,"Day":19240,"Scores":{"computer":87,"math":92,"physics":91}}
11{"Name":"StudentName","Age":23,"Id":8,"Weight":50.8,"Sex":true,"Day":19240,"Scores":{"computer":88,"math":93,"physics":92}}
12{"Name":"StudentName","Age":24,"Id":9,"Weight":50.9,"Sex":false,"Day":19240,"Scores":{"computer":89,"math":94,"physics":90}}
13*/
14
15SelectObjectRequest request = new SelectObjectRequest("bucketName", "test-parquet")
16        .withSelectType("parquet")
17        .withExpression("select * from BosObject s where s.Scores.computer > 85")
18        .withInputSerialization(new InputSerialization()
19                .withCompressionType("NONE"))
20        .withOutputSerialization(new OutputSerialization()
21                .withRecordDelimiter("\n"))
22        .withRequestProgress(false);
23SelectObjectResponse response = client.selectObject(request);
24
25// 输出返回的记录
26SelectObjectResponse.Messages messages = response.getMessages();
27while (messages.hasNext()) {
28    SelectObjectResponse.CommonMessage message = messages.next();
29    if (message.Type.equals("Records")) {
30        for (String record: message.getRecords()) {
31            System.out.println(record);
32        }
33    }
34}

1{"Name":"StudentName","Age":21,"Id":6,"Weight":50.6,"Sex":true,"Day":19240,"Scores":{"computer":86,"math":91,"physics":90}}
2{"Name":"StudentName","Age":22,"Id":7,"Weight":50.7,"Sex":false,"Day":19240,"Scores":{"computer":87,"math":92,"physics":91}}
3{"Name":"StudentName","Age":23,"Id":8,"Weight":50.8,"Sex":true,"Day":19240,"Scores":{"computer":88,"math":93,"physics":92}}
4{"Name":"StudentName","Age":24,"Id":9,"Weight":50.9,"Sex":false,"Day":19240,"Scores":{"computer":89,"math":94,"physics":90}}