@Test public void testConvertSchema() throws SchemaConversionException { WorkUnitState workUnitState = new WorkUnitState(); ObjectToStringConverter converter = new ObjectToStringConverter(); converter.init(workUnitState); Assert.assertEquals(converter.convertSchema(Object.class, workUnitState), String.class); }
@Override public Class<String> convertSchema(Object inputSchema, WorkUnitState workUnit) throws SchemaConversionException { return String.class; }
ObjectToStringConverter extends Converter<Object, Class<String>, Object, String> { @Override public Class<String> convertSchema(Object inputSchema, WorkUnitState workUnit) throws SchemaConversionException { return String.class; } }
ObjectToStringConverter extends Converter<Object, Class<String>, Object, String> { @Override public Class<String> convertSchema(Object inputSchema, WorkUnitState workUnit) throws SchemaConversionException { return String.class; }  }
ObjectToStringConverter extends Converter<Object, Class<String>, Object, String> { @Override public Class<String> convertSchema(Object inputSchema, WorkUnitState workUnit) throws SchemaConversionException { return String.class; }  @Override Class<String> convertSchema(Object inputSchema, WorkUnitState workUnit); @Override Iterable<String> convertRecord(Class<String> outputSchema, Object inputRecord, WorkUnitState workUnit); }
ObjectToStringConverter extends Converter<Object, Class<String>, Object, String> { @Override public Class<String> convertSchema(Object inputSchema, WorkUnitState workUnit) throws SchemaConversionException { return String.class; }  @Override Class<String> convertSchema(Object inputSchema, WorkUnitState workUnit); @Override Iterable<String> convertRecord(Class<String> outputSchema, Object inputRecord, WorkUnitState workUnit);  }