카프카에서 Avro 레코드를 받고 있습니다. 나는이 레코드들을 마루 파일들로 변환하고 싶다.Q : Avro를 메모리의 마루로 변환하기
final String fileName
SinkRecord record,
final AvroData avroData
final Schema avroSchema = avroData.fromConnectSchema(record.valueSchema());
CompressionCodecName compressionCodecName = CompressionCodecName.SNAPPY;
int blockSize = 256 * 1024 * 1024;
int pageSize = 64 * 1024;
Path path = new Path(fileName);
writer = new AvroParquetWriter<>(path, avroSchema, compressionCodecName, blockSize, pageSize);
지금, 이것은 아 브로가 변환을 나무 마루을 할 것입니다,하지만 디스크에 마루 파일을 작성합니다 : http://blog.cloudera.com/blog/2014/05/how-to-convert-existing-data-into-parquet/는
코드는 지금까지 대략 다음과 같습니다 :이 블로그 게시물을 다음입니다. 디스크에 임시 파일을 관리 할 필요가 없도록 파일을 메모리에 보관하는 쉬운 방법이 있는지 궁금합니다. 고마워요