Update GCS sample
@@ -26,11 +26,11 @@ Testing the Sample:
receiver.url='http://localhost:8006/inputStream', @map(type='json'))
define stream inputStream(key string, payload string, suffix string);
-@sink(type='google-cloud-storage' , credential.path='<credential.path>', bucket.name='<bucket-name>',storage.class='MULTI_REGION', flush.size="3", object.name='test-object-{{suffix}}',flush.timeout='60000', @map(type='text') )
+@sink(type='google-cloud-storage', credential.path='<credential.path>', bucket.name='<bucket.name>',
+ object.name='test-object-{{suffix}}',
+ @map(type='text'))
define stream outputStream(key string, payload string, suffix string);
-
from inputStream
select *
insert into outputStream;
-
