### Question:
InfluxLineProtocolReader extends AbstractControllerService implements RecordReaderFactory { @Override public RecordReader createRecordReader(final Map<String, String> variables, final InputStream in, long inputLength, final ComponentLog logger) throws MalformedRecordException, IOException, SchemaNotFoundException { Charset charset = Charset.forName(charsetName); return new InfluxLineProtocolRecordReader(in, charset); }  @OnEnabled void onEnabled(final ConfigurationContext context); @Override RecordReader createRecordReader(final Map<String, String> variables,
                                           final InputStream in,
										   long inputLength,
                                           final ComponentLog logger); static final PropertyDescriptor CHARSET; }### Answer:
@Test public void createReaderFromMap() throws SchemaNotFoundException, MalformedRecordException, IOException { RecordReader reader = readerFactory.createRecordReader(variables, null, -1, logger); Assert.assertNotNull(reader); }
@Test public void createReaderFromFlowFile() throws SchemaNotFoundException, MalformedRecordException, IOException { FlowFile flowFile = Mockito.mock(FlowFile.class); RecordReader reader = readerFactory.createRecordReader(flowFile, null, logger); Assert.assertNotNull(reader); }
@Test public void schemaNotNull() throws SchemaNotFoundException, MalformedRecordException, IOException { FlowFile flowFile = Mockito.mock(FlowFile.class); RecordReader reader = readerFactory.createRecordReader(flowFile, null, logger); RecordSchema schema = reader.getSchema(); Assert.assertNotNull(schema); }