@Test public void testNoMaxConcurrentTasks() { Map<String, Object> map = createMap(); map.remove(MAX_CONCURRENT_TASKS_KEY); assertEquals(DEFAULT_MAX_CONCURRENT_TASKS, createSchema(map, 0).convert().getMaxConcurrentTasks()); }
@Override public ProcessorSchema convert() { Map<String, Object> map = new HashMap<>(); map.put(NAME_KEY, name); map.put(CLASS_KEY, processorClass); map.put(MAX_CONCURRENT_TASKS_KEY, maxConcurrentTasks); map.put(SCHEDULING_STRATEGY_KEY, schedulingStrategy); map.put(SCHEDULING_PERIOD_KEY, schedulingPeriod); map.put(PENALIZATION_PERIOD_KEY, penalizationPeriod); map.put(YIELD_PERIOD_KEY, yieldPeriod); map.put(RUN_DURATION_NANOS_KEY, runDurationNanos); map.put(AUTO_TERMINATED_RELATIONSHIPS_LIST_KEY, autoTerminatedRelationshipsList); map.put(PROPERTIES_KEY, new HashMap<>(properties)); return new ProcessorSchema(map); }
ProcessorSchemaV1 extends BaseSchema implements ConvertableSchema<ProcessorSchema> { @Override public ProcessorSchema convert() { Map<String, Object> map = new HashMap<>(); map.put(NAME_KEY, name); map.put(CLASS_KEY, processorClass); map.put(MAX_CONCURRENT_TASKS_KEY, maxConcurrentTasks); map.put(SCHEDULING_STRATEGY_KEY, schedulingStrategy); map.put(SCHEDULING_PERIOD_KEY, schedulingPeriod); map.put(PENALIZATION_PERIOD_KEY, penalizationPeriod); map.put(YIELD_PERIOD_KEY, yieldPeriod); map.put(RUN_DURATION_NANOS_KEY, runDurationNanos); map.put(AUTO_TERMINATED_RELATIONSHIPS_LIST_KEY, autoTerminatedRelationshipsList); map.put(PROPERTIES_KEY, new HashMap<>(properties)); return new ProcessorSchema(map); } }
ProcessorSchemaV1 extends BaseSchema implements ConvertableSchema<ProcessorSchema> { @Override public ProcessorSchema convert() { Map<String, Object> map = new HashMap<>(); map.put(NAME_KEY, name); map.put(CLASS_KEY, processorClass); map.put(MAX_CONCURRENT_TASKS_KEY, maxConcurrentTasks); map.put(SCHEDULING_STRATEGY_KEY, schedulingStrategy); map.put(SCHEDULING_PERIOD_KEY, schedulingPeriod); map.put(PENALIZATION_PERIOD_KEY, penalizationPeriod); map.put(YIELD_PERIOD_KEY, yieldPeriod); map.put(RUN_DURATION_NANOS_KEY, runDurationNanos); map.put(AUTO_TERMINATED_RELATIONSHIPS_LIST_KEY, autoTerminatedRelationshipsList); map.put(PROPERTIES_KEY, new HashMap<>(properties)); return new ProcessorSchema(map); } ProcessorSchemaV1(Map map); }
ProcessorSchemaV1 extends BaseSchema implements ConvertableSchema<ProcessorSchema> { @Override public ProcessorSchema convert() { Map<String, Object> map = new HashMap<>(); map.put(NAME_KEY, name); map.put(CLASS_KEY, processorClass); map.put(MAX_CONCURRENT_TASKS_KEY, maxConcurrentTasks); map.put(SCHEDULING_STRATEGY_KEY, schedulingStrategy); map.put(SCHEDULING_PERIOD_KEY, schedulingPeriod); map.put(PENALIZATION_PERIOD_KEY, penalizationPeriod); map.put(YIELD_PERIOD_KEY, yieldPeriod); map.put(RUN_DURATION_NANOS_KEY, runDurationNanos); map.put(AUTO_TERMINATED_RELATIONSHIPS_LIST_KEY, autoTerminatedRelationshipsList); map.put(PROPERTIES_KEY, new HashMap<>(properties)); return new ProcessorSchema(map); } ProcessorSchemaV1(Map map); @Override ProcessorSchema convert(); String getName(); @Override int getVersion(); }
ProcessorSchemaV1 extends BaseSchema implements ConvertableSchema<ProcessorSchema> { @Override public ProcessorSchema convert() { Map<String, Object> map = new HashMap<>(); map.put(NAME_KEY, name); map.put(CLASS_KEY, processorClass); map.put(MAX_CONCURRENT_TASKS_KEY, maxConcurrentTasks); map.put(SCHEDULING_STRATEGY_KEY, schedulingStrategy); map.put(SCHEDULING_PERIOD_KEY, schedulingPeriod); map.put(PENALIZATION_PERIOD_KEY, penalizationPeriod); map.put(YIELD_PERIOD_KEY, yieldPeriod); map.put(RUN_DURATION_NANOS_KEY, runDurationNanos); map.put(AUTO_TERMINATED_RELATIONSHIPS_LIST_KEY, autoTerminatedRelationshipsList); map.put(PROPERTIES_KEY, new HashMap<>(properties)); return new ProcessorSchema(map); } ProcessorSchemaV1(Map map); @Override ProcessorSchema convert(); String getName(); @Override int getVersion();  }