JSONParser extends Transform<StructuredRecord, StructuredRecord> { public JSONParser(Config config) { this.config = config; } JSONParser(Config config); @Override void configurePipeline(PipelineConfigurer pipelineConfigurer); @Override void prepareRun(StageSubmitterContext context); @Override void initialize(TransformContext context); @Override void transform(StructuredRecord input, Emitter<StructuredRecord> emitter);  }
@Test public void testJSONParser() throws Exception { JSONParser.Config config = new JSONParser.Config("body", "", OUTPUT1.toString()); testJsonParserConfig(config); }