class QueueMapper implements Mapper, JobStateAware, Supplier<DIPipeline>, Delegated {

    @Override
    public List<Mapper> split(final long desiredSize) {
        return singletonList(this);
    }

    public  QueueMapper(final String plugin, final String family, final String name,
            final PTransform<PBegin, PCollection<Record>> transform);

}