@ VisibleForTesting static void updateRecordForHDFS ( Record record , boolean roll , String avroSchema , String location ) { if ( roll ) { record . getHeader ( ) . setAttribute ( HDFS_HEADER_ROLL , "true" ) ; } record . getHeader ( ) . setAttribute ( HDFS_HEADER_AVROSCHEMA , avroSchema ) ; record . getHeader ( ) . setAttribute ( HDFS_HEADER_TARGET_DIRECTORY , location ) ; LOG . trace ( "Record {} will be stored in {} path: roll({}), avro schema: {}" , record . getHeader ( ) . getSourceId ( ) , location , roll , avroSchema ) ; }
Add header information to send to HDFS