@@ -245,60 +245,6 @@ class S3BucketOpsIntegrationTest {
245245 }
246246 }
247247
248- @Test
249- fun testSelectObjectEventStream (): Unit = runBlocking {
250- // upload our content to select from
251- val objKey = " developers.csv"
252-
253- val content = """
254- Name,PhoneNumber,City,Occupation
255- Sam,(949) 555-6701,Irvine,Solutions Architect
256- Vinod,(949) 555-6702,Los Angeles,Solutions Architect
257- Jeff,(949) 555-6703,Seattle,AWS Evangelist
258- Jane,(949) 555-6704,Chicago,Developer
259- Sean,(949) 555-6705,Indianapolis,Developer
260- Mary,(949) 555-6706,Detroit,Developer
261- Kate,(949) 555-6707,Boston,Solutions Architect
262- """ .trimIndent()
263-
264- client.putObject {
265- bucket = testBucket
266- key = objKey
267- body = ByteStream .fromString(content)
268- }
269-
270- // select content as an event stream
271- val req = SelectObjectContentRequest {
272- bucket = testBucket
273- key = objKey
274- expressionType = ExpressionType .Sql
275- expression = """ SELECT * FROM s3object s where s."Name" = 'Jane'"""
276- inputSerialization {
277- csv {
278- fileHeaderInfo = FileHeaderInfo .Use
279- }
280- compressionType = CompressionType .None
281- }
282- outputSerialization {
283- csv { }
284- }
285- }
286-
287- val events = client.selectObjectContent(req) { resp ->
288- // collect flow to list
289- resp.payload!! .toList()
290- }
291-
292- assertEquals(3 , events.size)
293-
294- val records = assertIs<SelectObjectContentEventStream .Records >(events[0 ])
295- assertIs<SelectObjectContentEventStream .Stats >(events[1 ])
296- assertIs<SelectObjectContentEventStream .End >(events[2 ])
297-
298- val expectedRecord = " Jane,(949) 555-6704,Chicago,Developer\n "
299- assertEquals(expectedRecord, records.value.payload?.decodeToString())
300- }
301-
302248 @Test
303249 fun testPutObjectWithChecksum (): Unit = runBlocking {
304250 val contents = " AAAAAAAAAA"
0 commit comments