### Question:
PartitionMapperImpl extends LifecycleImpl implements Mapper, Delegated { @Override public Input create() { lazyInit(); final Serializable input = Serializable.class.cast(doInvoke(inputFactory)); if (isStream()) { return new StreamingInputImpl(rootName(), inputName, plugin(), input, loadRetryConfiguration()); } return new InputImpl(rootName(), inputName, plugin(), input); } PartitionMapperImpl(final String rootName, final String name, final String inputName, final String plugin,
            final boolean stream, final Serializable instance); protected  PartitionMapperImpl(); @Override long assess(); @Override List<Mapper> split(final long desiredSize); @Override Input create(); @Override boolean isStream(); @Override Object getDelegate();  }### Answer:
@Test void create() { assertInput(new PartitionMapperImpl("Root", "Test", null, "Plugin", false, new SampleMapper())); }
@Test void createStreaming() { final PartitionMapperImpl mapper = new PartitionMapperImpl("Root", "Test", null, "Plugin", true, new SampleMapper()); final Input input = mapper.create(); assertTrue(StreamingInputImpl.class.isInstance(input)); }