Examples of ChangeSinkChangeSourceManager

Examples of org.openstreetmap.osmosis.core.pipeline.v0_6.ChangeSinkChangeSourceManager

29
30
31
32
33
34
35
36
37
38
39
      taskConfig,
      ARG_PORT,
      getDefaultIntegerArgument(taskConfig, DEFAULT_PORT)
    );
   
    return new ChangeSinkChangeSourceManager(
      taskConfig.getId(),
      new ReplicationSequenceServer(port),
      taskConfig.getPipeArgs()
    );
  }
View Full Code Here

Examples of org.openstreetmap.osmosis.core.pipeline.v0_6.ChangeSinkChangeSourceManager

18
19
20
21
22
23
24
25
26
27
28
   * {@inheritDoc}
   */
  @Override
  protected TaskManager createTaskManagerImpl(TaskConfiguration taskConfig) {
   
    return new ChangeSinkChangeSourceManager(
      taskConfig.getId(),
      new ChangeTagSorter(),
      taskConfig.getPipeArgs()
    );
  }
View Full Code Here

Examples of org.openstreetmap.osmosis.core.pipeline.v0_6.ChangeSinkChangeSourceManager

17
18
19
20
21
22
23
24
25
26
27
  /**
   * {@inheritDoc}
   */
  @Override
  protected TaskManager createTaskManagerImpl(TaskConfiguration taskConfig) {
    return new ChangeSinkChangeSourceManager(
      taskConfig.getId(),
      new ChangeSimplifier(),
      taskConfig.getPipeArgs()
    );
  }
View Full Code Here

Examples of org.openstreetmap.osmosis.core.pipeline.v0_6.ChangeSinkChangeSourceManager

33
34
35
36
37
38
39
    label = getStringArgument(taskConfig, ARG_LABEL, DEFAULT_LABEL);

    // Build the task object.
    task = new ChangeProgressLogger(interval * 1000, label);
   
    return new ChangeSinkChangeSourceManager(taskConfig.getId(), task, taskConfig.getPipeArgs());
  }
View Full Code Here

Examples of org.openstreetmap.osmosis.core.pipeline.v0_6.ChangeSinkChangeSourceManager

12
13
14
15
16
17
18
19
  @Override
  protected TaskManager createTaskManagerImpl(TaskConfiguration taskConfig) {
    String configFile =
        getStringArgument(taskConfig, "file", getDefaultStringArgument(taskConfig, "transform.xml"));
    String statsFile = getStringArgument(taskConfig, "stats", null);
    return new ChangeSinkChangeSourceManager(taskConfig.getId(), new TransformChangeTask(configFile, statsFile),
        taskConfig.getPipeArgs());
  }
View Full Code Here

Examples of org.openstreetmap.osmosis.core.pipeline.v0_6.ChangeSinkChangeSourceManager

30
31
32
33
34
35
36
37
38
39
        getDefaultStringArgument(taskConfig, DEFAULT_WORKING_DIRECTORY));

    // Convert argument strings to strongly typed objects.
    workingDirectory = new File(workingDirectoryString);

    return new ChangeSinkChangeSourceManager(
        taskConfig.getId(),
        new ReplicationToChangeWriter(workingDirectory),
        taskConfig.getPipeArgs());
  }
View Full Code Here

Examples of org.openstreetmap.osmosis.core.pipeline.v0_6.ChangeSinkChangeSourceManager

89
90
91
92
93
94
95
96
97
98
99
        ARG_COMPARATOR_TYPE,
        getDefaultStringArgument(taskConfig, defaultComparatorType)
      )
    );
   
    return new ChangeSinkChangeSourceManager(
      taskConfig.getId(),
      new ChangeSorter(comparator),
      taskConfig.getPipeArgs()
    );
  }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.