@Test public void testGetInstance() { KafkaWorkUnitPacker anotherPacker = KafkaWorkUnitPacker.getInstance(source, state); Assert.assertTrue(anotherPacker instanceof KafkaSingleLevelWorkUnitPacker); }
public static KafkaWorkUnitPacker getInstance(AbstractSource<?, ?> source, SourceState state) { return getInstance(source, state, Optional.absent()); }
KafkaWorkUnitPacker { public static KafkaWorkUnitPacker getInstance(AbstractSource<?, ?> source, SourceState state) { return getInstance(source, state, Optional.absent()); } }
KafkaWorkUnitPacker { public static KafkaWorkUnitPacker getInstance(AbstractSource<?, ?> source, SourceState state) { return getInstance(source, state, Optional.absent()); } protected  KafkaWorkUnitPacker(AbstractSource<?, ?> source, SourceState state); }
KafkaWorkUnitPacker { public static KafkaWorkUnitPacker getInstance(AbstractSource<?, ?> source, SourceState state) { return getInstance(source, state, Optional.absent()); } protected  KafkaWorkUnitPacker(AbstractSource<?, ?> source, SourceState state); static KafkaWorkUnitPacker getInstance(AbstractSource<?, ?> source, SourceState state); static KafkaWorkUnitPacker getInstance(AbstractSource<?, ?> source, SourceState state,
      Optional<MetricContext> metricContext); static KafkaWorkUnitPacker getInstance(PackerType packerType, AbstractSource<?, ?> source, SourceState state, Optional<MetricContext> metricContext); double setWorkUnitEstSizes(Map<String, List<WorkUnit>> workUnitsByTopic); abstract List<WorkUnit> pack(Map<String, List<WorkUnit>> workUnitsByTopic, int numContainers); }
KafkaWorkUnitPacker { public static KafkaWorkUnitPacker getInstance(AbstractSource<?, ?> source, SourceState state) { return getInstance(source, state, Optional.absent()); } protected  KafkaWorkUnitPacker(AbstractSource<?, ?> source, SourceState state); static KafkaWorkUnitPacker getInstance(AbstractSource<?, ?> source, SourceState state); static KafkaWorkUnitPacker getInstance(AbstractSource<?, ?> source, SourceState state,
      Optional<MetricContext> metricContext); static KafkaWorkUnitPacker getInstance(PackerType packerType, AbstractSource<?, ?> source, SourceState state, Optional<MetricContext> metricContext); double setWorkUnitEstSizes(Map<String, List<WorkUnit>> workUnitsByTopic); abstract List<WorkUnit> pack(Map<String, List<WorkUnit>> workUnitsByTopic, int numContainers); static final String KAFKA_WORKUNIT_PACKER_TYPE; static final String KAFKA_WORKUNIT_PACKER_CUSTOMIZED_TYPE; static final String KAFKA_WORKUNIT_SIZE_ESTIMATOR_TYPE; static final String KAFKA_WORKUNIT_SIZE_ESTIMATOR_CUSTOMIZED_TYPE; static final String MIN_MULTIWORKUNIT_LOAD; static final String MAX_MULTIWORKUNIT_LOAD; }