@Test public void testMap_NullFromJythonMapper() throws IOException, InterruptedException { LineMapper lineMapper = new JythonLineMapper(pythonCode, "mapsNothing"); lineMapper.mapLine("inputValue", mappingContext); verify(mappingContext, never()).writeRecord(any(Record.class)); }
@Override public void mapLine(String inputLine, LineMappingContext context) { mapperCallable.__call__(new PyString(inputLine), Py.java2py(context)); }
JythonLineMapper implements LineMapper { @Override public void mapLine(String inputLine, LineMappingContext context) { mapperCallable.__call__(new PyString(inputLine), Py.java2py(context)); } }
JythonLineMapper implements LineMapper { @Override public void mapLine(String inputLine, LineMappingContext context) { mapperCallable.__call__(new PyString(inputLine), Py.java2py(context)); } JythonLineMapper(String pythonCode, String recordMapperSymbol);  JythonLineMapper(String pythonCode, String recordMapperSymbol, Writer stderrWriter); }
JythonLineMapper implements LineMapper { @Override public void mapLine(String inputLine, LineMappingContext context) { mapperCallable.__call__(new PyString(inputLine), Py.java2py(context)); } JythonLineMapper(String pythonCode, String recordMapperSymbol);  JythonLineMapper(String pythonCode, String recordMapperSymbol, Writer stderrWriter); @Override void mapLine(String inputLine, LineMappingContext context); }
JythonLineMapper implements LineMapper { @Override public void mapLine(String inputLine, LineMappingContext context) { mapperCallable.__call__(new PyString(inputLine), Py.java2py(context)); } JythonLineMapper(String pythonCode, String recordMapperSymbol);  JythonLineMapper(String pythonCode, String recordMapperSymbol, Writer stderrWriter); @Override void mapLine(String inputLine, LineMappingContext context);  }