@Test (expected = MorphlineRuntimeException.class) public void executePipelineProcessError( final @Mocked MorphlineUtils.Pipeline pipeline, final @Mocked Command morphline ) throws Exception { final Record inputRecord = new Record(); new Expectations() {{ morphline.process(inputRecord); result = false; }}; MorphlineUtils.executePipeline(pipeline, inputRecord); }
public static List<Record> executePipeline(Pipeline pipeline, Record inputRecord) { return executePipeline(pipeline, inputRecord, true); }
MorphlineUtils { public static List<Record> executePipeline(Pipeline pipeline, Record inputRecord) { return executePipeline(pipeline, inputRecord, true); } }
MorphlineUtils { public static List<Record> executePipeline(Pipeline pipeline, Record inputRecord) { return executePipeline(pipeline, inputRecord, true); }  }
MorphlineUtils { public static List<Record> executePipeline(Pipeline pipeline, Record inputRecord) { return executePipeline(pipeline, inputRecord, true); }  static Pipeline getPipeline(String morphlineFile, String morphlineId); static Pipeline setPipeline(String morphlineFile, String morphlineId, Collector collector, boolean isProduction); static List<Record> executePipeline(Pipeline pipeline, Record inputRecord); static List<Record> executePipeline(Pipeline pipeline, Record inputRecord, boolean errorOnEmpty); @SuppressWarnings("serial") static FlatMapFunction<Row, Row> morphlineMapper(final String morphlineFile, final String morphlineId,
                                                          final StructType outputSchema, final boolean errorOnEmpty); static Row convertToRow(StructType schema, Record record); }
MorphlineUtils { public static List<Record> executePipeline(Pipeline pipeline, Record inputRecord) { return executePipeline(pipeline, inputRecord, true); }  static Pipeline getPipeline(String morphlineFile, String morphlineId); static Pipeline setPipeline(String morphlineFile, String morphlineId, Collector collector, boolean isProduction); static List<Record> executePipeline(Pipeline pipeline, Record inputRecord); static List<Record> executePipeline(Pipeline pipeline, Record inputRecord, boolean errorOnEmpty); @SuppressWarnings("serial") static FlatMapFunction<Row, Row> morphlineMapper(final String morphlineFile, final String morphlineId,
                                                          final StructType outputSchema, final boolean errorOnEmpty); static Row convertToRow(StructType schema, Record record);  }