@@ -357,7 +357,7 @@ public class Application {
357357 try {
358358 Airbyte sdk = Airbyte . builder()
359359 .setSecurity(new Security (" accusamus" ) {{
360- bearerAuth = " YOUR_BEARER_TOKEN_HERE " ;
360+ bearerAuth = " " ;
361361 }})
362362 .build();
363363
@@ -404,7 +404,7 @@ public class Application {
404404 try {
405405 Airbyte sdk = Airbyte . builder()
406406 .setSecurity(new Security (" tempora" ) {{
407- bearerAuth = " YOUR_BEARER_TOKEN_HERE " ;
407+ bearerAuth = " " ;
408408 }})
409409 .build();
410410
@@ -441,7 +441,7 @@ public class Application {
441441 try {
442442 Airbyte sdk = Airbyte . builder()
443443 .setSecurity(new Security (" quod" ) {{
444- bearerAuth = " YOUR_BEARER_TOKEN_HERE " ;
444+ bearerAuth = " " ;
445445 }})
446446 .build();
447447
@@ -478,7 +478,7 @@ public class Application {
478478 try {
479479 Airbyte sdk = Airbyte . builder()
480480 .setSecurity(new Security (" qui" ) {{
481- bearerAuth = " YOUR_BEARER_TOKEN_HERE " ;
481+ bearerAuth = " " ;
482482 }})
483483 .build();
484484
@@ -853,7 +853,7 @@ public class Application {
853853 try {
854854 Airbyte sdk = Airbyte . builder()
855855 .setSecurity(new Security (" cupiditate" ) {{
856- bearerAuth = " YOUR_BEARER_TOKEN_HERE " ;
856+ bearerAuth = " " ;
857857 }})
858858 .build();
859859
@@ -1229,37 +1229,37 @@ public class Application {
12291229 try {
12301230 Airbyte sdk = Airbyte . builder()
12311231 .setSecurity(new Security (" consequatur" ) {{
1232- bearerAuth = " YOUR_BEARER_TOKEN_HERE " ;
1232+ bearerAuth = " " ;
12331233 }})
12341234 .build();
12351235
12361236 PutDestinationRequest req = new PutDestinationRequest (" est" ) {{
1237- destinationPutRequest = new DestinationPutRequest ( new DestinationS3 (DestinationS3S3 . S3 , new DestinationS3FormatParquetColumnarStorage (DestinationS3FormatParquetColumnarStorageFormatType . PARQUET ) {{
1238- blockSizeMb = 606476L ;
1239- compressionCodec = DestinationS3FormatParquetColumnarStorageCompressionCodec . GZIP ;
1240- dictionaryEncoding = false ;
1241- dictionaryPageSizeKb = 218403L ;
1242- formatType = DestinationS3FormatParquetColumnarStorageFormatType . PARQUET ;
1243- maxPaddingSizeMb = 961571L ;
1244- pageSizeKb = 455169L ;
1245- }}, " consectetur" , " vero" , DestinationS3S3BucketRegion . US_GOV_EAST1 ) {{
1246- accessKeyId = " porro" ;
1237+ destinationPutRequest = new DestinationPutRequest ( new DestinationS3 (DestinationS3S3 . S3 , new DestinationS3FormatJSONLinesNewlineDelimitedJSON (DestinationS3FormatJSONLinesNewlineDelimitedJSONFormatType . JSONL ) {{
1238+ compression = new DestinationS3FormatJSONLinesNewlineDelimitedJSONCompressionNoCompression () {{
1239+ compressionType = DestinationS3FormatJSONLinesNewlineDelimitedJSONCompressionNoCompressionCompressionType . NO_COMPRESSION ;
1240+ }};
1241+ flattening = DestinationS3FormatJSONLinesNewlineDelimitedJSONFlattening . NO_FLATTENING ;
1242+ formatType = DestinationS3FormatJSONLinesNewlineDelimitedJSONFormatType . JSONL ;
1243+ }}, " airbyte_sync" , " data_sync/test" , DestinationS3S3BucketRegion . CA_CENTRAL1 ) {{
1244+ accessKeyId = " A012345678910EXAMPLE" ;
12471245 destinationType = DestinationS3S3 . S3 ;
1248- fileNamePattern = " doloribus" ;
1249- format = new DestinationS3FormatCSVCommaSeparatedValues (DestinationS3FormatCSVCommaSeparatedValuesFlattening . NO_FLATTENING , DestinationS3FormatCSVCommaSeparatedValuesFormatType . CSV ) {{
1250- compression = new DestinationS3FormatCSVCommaSeparatedValuesCompressionGZIP () {{
1251- compressionType = DestinationS3FormatCSVCommaSeparatedValuesCompressionGZIPCompressionType . GZIP ;
1252- }};
1253- flattening = DestinationS3FormatCSVCommaSeparatedValuesFlattening . ROOT_LEVEL_FLATTENING ;
1254- formatType = DestinationS3FormatCSVCommaSeparatedValuesFormatType . CSV ;
1246+ fileNamePattern = " {part_number}" ;
1247+ format = new DestinationS3FormatParquetColumnarStorage (DestinationS3FormatParquetColumnarStorageFormatType . PARQUET ) {{
1248+ blockSizeMb = 128L ;
1249+ compressionCodec = DestinationS3FormatParquetColumnarStorageCompressionCodec . SNAPPY ;
1250+ dictionaryEncoding = false ;
1251+ dictionaryPageSizeKb = 1024L ;
1252+ formatType = DestinationS3FormatParquetColumnarStorageFormatType . PARQUET ;
1253+ maxPaddingSizeMb = 8L ;
1254+ pageSizeKb = 1024L ;
12551255 }};
1256- s3BucketName = " quae " ;
1257- s3BucketPath = " laudantium " ;
1258- s3BucketRegion = DestinationS3S3BucketRegion . AP_SOUTHEAST2 ;
1259- s3Endpoint = " occaecati " ;
1260- s3PathFormat = " voluptatibus " ;
1261- secretAccessKey = " quisquam " ;
1262- }}, " dignissimos " );;
1256+ s3BucketName = " airbyte_sync " ;
1257+ s3BucketPath = " data_sync/test " ;
1258+ s3BucketRegion = DestinationS3S3BucketRegion . EU_SOUTH1 ;
1259+ s3Endpoint = " http://localhost:9000 " ;
1260+ s3PathFormat = " ${NAMESPACE}/${STREAM_NAME}/${YEAR}_${MONTH}_${DAY}_${EPOCH}_ " ;
1261+ secretAccessKey = " a012345678910ABCDEFGH/AbCdEfGhEXAMPLEKEY " ;
1262+ }}, " odio " );;
12631263 }};
12641264
12651265 PutDestinationResponse res = sdk. destinations. putDestination(req);
0 commit comments