Skip to content

Commit 139815d

Browse files
committed
aws: Implement a handler for parquet compression
Signed-off-by: Hiroshi Hatake <[email protected]>
1 parent 2d4aef5 commit 139815d

File tree

2 files changed

+11
-3
lines changed

2 files changed

+11
-3
lines changed

include/fluent-bit/aws/flb_aws_compress.h

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -21,9 +21,10 @@
2121
#define FLB_AWS_COMPRESS
2222

2323
#include <sys/types.h>
24-
#define FLB_AWS_COMPRESS_NONE 0
25-
#define FLB_AWS_COMPRESS_GZIP 1
26-
#define FLB_AWS_COMPRESS_ARROW 2
24+
#define FLB_AWS_COMPRESS_NONE 0
25+
#define FLB_AWS_COMPRESS_GZIP 1
26+
#define FLB_AWS_COMPRESS_ARROW 2
27+
#define FLB_AWS_COMPRESS_PARQUET 3
2728

2829
/*
2930
* Get compression type from compression keyword. The return value is used to identify

src/aws/flb_aws_compress.c

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -54,6 +54,13 @@ static const struct compression_option compression_options[] = {
5454
"arrow",
5555
&out_s3_compress_arrow
5656
},
57+
#endif
58+
#ifdef FLB_HAVE_ARROW_PARQUET
59+
{
60+
FLB_AWS_COMPRESS_PARQUET,
61+
"parquet",
62+
&out_s3_compress_parquet
63+
},
5764
#endif
5865
{ 0 }
5966
};

0 commit comments

Comments
 (0)