November 2019
Intermediate to advanced
304 pages
8h 40m
English
TransformProcess transformProcess = new TransformProcess.Builder(schema) .removeColumns("RowNumber","CustomerId","Surname") .build();
DataQualityAnalysis analysis = AnalyzeLocal.analyzeQuality(schema,recordReader); System.out.println(analysis);
Condition condition = new NullWritableColumnCondition("columnName"); TransformProcess transformProcess = new TransformProcess.Builder(schema) .conditionalReplaceValueTransform("columnName",new IntWritable(0),condition) .build();