uk.gov.dstl.baleen.core.pipelines.YamlPipelineConfiguration.<init>()方法的使用及代码示例

x33g5p2x  于2022-02-05 转载在 其他  
字(9.6k)|赞(0)|评价(0)|浏览(129)

本文整理了Java中uk.gov.dstl.baleen.core.pipelines.YamlPipelineConfiguration.<init>()方法的一些代码示例，展示了YamlPipelineConfiguration.<init>()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。YamlPipelineConfiguration.<init>()方法的具体详情如下：
包路径：uk.gov.dstl.baleen.core.pipelines.YamlPipelineConfiguration
类名称：YamlPipelineConfiguration
方法名：<init>

YamlPipelineConfiguration.<init>介绍

[英]Construct empty configuration
[中]构造空配置

代码示例

代码示例来源：origin: dstl/baleen

  1. /**
  2.  * Cosntruct a new BaleenJob
  3.  *
  4.  * @param name The name of the job
  5.  * @param originalYaml The original YAML
  6.  * @param scheduler The scheduler (i.e. collection reader)
  7.  * @param tasks List of tasks (i.e. annotators)
  8.  * @throws IOException if unable to construct
  9.  */
  10. public BaleenJob(
  11.   String name, String originalYaml, CollectionReader scheduler, List<AnalysisEngine> tasks)
  12.   throws IOException {
  13.  this(name, new YamlPipelineConfiguration(originalYaml), scheduler, tasks);
  14. }

代码示例来源：origin: dstl/baleen

  1. /**
  2.  * Construct a JobBuilder from the name and YAML
  3.  *
  4.  * @param name Pipeline name
  5.  * @param yaml Pipeline YAML
  6.  * @throws IOException if unable to read config
  7.  * @deprecated Use {@link JobBuilder#JobBuilder(String, PipelineConfiguration)}
  8.  */
  9. @Deprecated
  10. public JobBuilder(String name, String yaml) throws IOException {
  11.  this(name, new YamlPipelineConfiguration(yaml));
  12. }

代码示例来源：origin: dstl/baleen

  1. /**
  2.  * Construct a PipelineBuilder from the name and YAML
  3.  *
  4.  * @param name Pipeline name
  5.  * @param yaml Pipeline YAML
  6.  * @throws IOException
  7.  * @deprecated Use {@link PipelineBuilder#PipelineBuilder(String, PipelineConfiguration)}
  8.  */
  9. @Deprecated
  10. public PipelineBuilder(String name, String yaml) throws IOException {
  11.  this(name, new YamlPipelineConfiguration(yaml));
  12. }

代码示例来源：origin: dstl/baleen

  1. /**
  2.  * Create a new pipeline from the provided YAML, with the given name. If multiplicity is greater
  3.  * than 1 names will be suffixed with '-n' for each multiple.
  4.  */
  5. public List<BaleenPipeline> create(String name, InputStream yaml, int multiplicity)
  6.   throws BaleenException {
  7.  try {
  8.   return create(name, new YamlPipelineConfiguration(yaml), multiplicity);
  9.  } catch (IOException e) {
  10.   throw new BaleenException(e);
  11.  }
  12. }

代码示例来源：origin: dstl/baleen

  1. /**
  2.  * Create a new pipeline from the provided YAML file, with the given name. If multiplicity is
  3.  * greater than 1 names will be suffixed with '-n' for each multiple.
  4.  */
  5. public List<BaleenPipeline> create(String name, File file, int multiplicity)
  6.   throws BaleenException {
  7.  try {
  8.   return create(name, new YamlPipelineConfiguration(file), multiplicity);
  9.  } catch (IOException e) {
  10.   throw new BaleenException(e);
  11.  }
  12. }

代码示例来源：origin: dstl/baleen

  1. protected BaleenJob wrapInJob(Class<? extends BaleenTask>... taskClasses)
  2.   throws BaleenException, IOException {
  3.  String yaml = getYaml(taskClasses);
  4.  return (BaleenJob) jobManager.create("testjob", new YamlPipelineConfiguration(yaml));
  5. }

代码示例来源：origin: dstl/baleen

  1. protected BaleenJob wrapInJob(Class<? extends BaleenTask> taskClass, Map<String, String> params)
  2.   throws BaleenException, IOException {
  3.  String yaml = getYaml(taskClass, params);
  4.  return (BaleenJob) jobManager.create("testjob", new YamlPipelineConfiguration(yaml));
  5. }

代码示例来源：origin: dstl/baleen

  1. @Test
  2. public void testEmpty() throws Exception {
  3.  BaleenJob job =
  4.    new BaleenJob("name", new YamlPipelineConfiguration(), null, Collections.emptyList());
  5.  doReturn(Optional.of(job)).when(manager).get(anyString());
  6.  ServletCaller caller = new ServletCaller();
  7.  caller.addParameter("name", "name");
  8.  caller.doGet(new JobConfigServlet(manager));
  9.  assertEquals("", caller.getResponseBody());
  10. }

代码示例来源：origin: dstl/baleen

  1. @Test
  2. public void testNameAndYaml() throws IOException {
  3.  BaleenPipeline bop =
  4.    new BaleenPipeline(
  5.      "Test Name",
  6.      new YamlPipelineConfiguration("Test YAML"),
  7.      new NoOpOrderer(),
  8.      null,
  9.      Collections.emptyList(),
  10.      Collections.emptyList());
  11.  assertEquals("Test Name", bop.getName());
  12.  assertEquals("Test YAML", bop.originalConfig());
  13.  // TODO: Test orderedYaml
  14. }

代码示例来源：origin: dstl/baleen

  1. @Test
  2. public void testEmpty() throws Exception {
  3.  BaleenPipeline pipeline =
  4.    new BaleenPipeline(
  5.      "name",
  6.      new YamlPipelineConfiguration(),
  7.      new NoOpOrderer(),
  8.      null,
  9.      Collections.emptyList(),
  10.      Collections.emptyList());
  11.  doReturn(Optional.of(pipeline)).when(manager).get(anyString());
  12.  ServletCaller caller = new ServletCaller();
  13.  caller.addParameter("name", "name");
  14.  caller.doGet(new PipelineConfigServlet(manager));
  15.  assertEquals("", caller.getResponseBody());
  16. }

代码示例来源：origin: dstl/baleen

  1. @Test
  2. public void testErrorContentExtractorNotFound() throws Exception {
  3.  String yaml =
  4.    Files.asCharSource(getFile("errorNotFoundCEConfig.yaml"), StandardCharsets.UTF_8).read();
  5.  PipelineBuilder pb = new PipelineBuilder("Test Pipeline", new YamlPipelineConfiguration(yaml));
  6.  try {
  7.   pb.createNewPipeline();
  8.   fail("Expected exception not thrown");
  9.  } catch (BaleenException be) {
  10.   // Expected exception, do nothing
  11.  }
  12. }

代码示例来源：origin: dstl/baleen

  1. @Test
  2.  public void testWithConfig() throws Exception {
  3.   BaleenPipeline pipeline =
  4.     new BaleenPipeline(
  5.       "name",
  6.       new YamlPipelineConfiguration("Config"),
  7.       new NoOpOrderer(),
  8.       null,
  9.       Collections.emptyList(),
  10.       Collections.emptyList());
  11.   doReturn(Optional.of(pipeline)).when(manager).get(anyString());
  13.   ServletCaller caller = new ServletCaller();
  14.   caller.addParameter("name", "name");
  15.   caller.doGet(new PipelineConfigServlet(manager));
  16.   assertEquals("Config", caller.getResponseBody());
  17.  }
  18. }

代码示例来源：origin: dstl/baleen

  1. @Test
  2. public void testErrorNoCR() throws Exception {
  3.  String yaml =
  4.    Files.asCharSource(getFile("errorNoCRConfig.yaml"), StandardCharsets.UTF_8).read();
  5.  PipelineBuilder pb = new PipelineBuilder("Test Pipeline", new YamlPipelineConfiguration(yaml));
  6.  try {
  7.   pb.createNewPipeline();
  8.   fail("Expected exception not thrown");
  9.  } catch (BaleenException be) {
  10.   // Expected exception, do nothing
  11.  }
  12. }

代码示例来源：origin: dstl/baleen

  1. @Test
  2. public void testErrorNotFoundCR() throws Exception {
  3.  String yaml =
  4.    Files.asCharSource(getFile("errorNotFoundCRConfig.yaml"), StandardCharsets.UTF_8).read();
  5.  PipelineBuilder pb = new PipelineBuilder("Test Pipeline", new YamlPipelineConfiguration(yaml));
  6.  try {
  7.   pb.createNewPipeline();
  8.   fail("Expected exception not thrown");
  9.  } catch (BaleenException be) {
  10.   // Expected exception, do nothing
  11.  }
  12. }

代码示例来源：origin: dstl/baleen

  1. @Test
  2. public void testLegacy() throws Exception {
  3.  String yaml = Files.asCharSource(getFile("legacyConfig.yaml"), StandardCharsets.UTF_8).read();
  4.  PipelineBuilder pb = new PipelineBuilder("Test Pipeline", new YamlPipelineConfiguration(yaml));
  5.  BaleenPipeline pipeline = pb.createNewPipeline();
  6.  assertEquals("Test Pipeline", pipeline.getName());
  7.  assertEquals(yaml, pipeline.originalConfig());
  8.  // Will throw an exception if the content extractor was not found resource wasn't initialized
  9. }

代码示例来源：origin: dstl/baleen

  1. @Test
  2. public void testErrorNoClass() throws Exception {
  3.  String yaml =
  4.    Files.asCharSource(getFile("errorNoClassConfig.yaml"), StandardCharsets.UTF_8).read();
  5.  PipelineBuilder pb = new PipelineBuilder("Test Pipeline", new YamlPipelineConfiguration(yaml));
  6.  BaleenPipeline pipeline = pb.createNewPipeline();
  7.  CollectionReader cr = pipeline.collectionReader();
  8.  assertEquals("uk.gov.dstl.baleen.testing.DummyCollectionReader", cr.getMetaData().getName());
  9.  List<AnalysisEngine> annotators = pipeline.annotators();
  10.  assertEquals(0, annotators.size());
  11. }

代码示例来源：origin: dstl/baleen

  1. @Test
  2. public void testResources() throws Exception {
  3.  String yaml = Files.asCharSource(getFile("resourceConfig.yaml"), StandardCharsets.UTF_8).read();
  4.  PipelineBuilder pb = new PipelineBuilder("Test Pipeline", new YamlPipelineConfiguration(yaml));
  5.  BaleenPipeline pipeline = pb.createNewPipeline();
  6.  assertEquals("Test Pipeline", pipeline.getName());
  7.  assertEquals(yaml, pipeline.originalConfig());
  8.  // Will throw an exception if the resource wasn't initialized
  9. }

代码示例来源：origin: dstl/baleen

  1. @Test
  2. public void testErrorNotFound() throws Exception {
  3.  String yaml =
  4.    Files.asCharSource(getFile("errorNotFoundConfig.yaml"), StandardCharsets.UTF_8).read();
  5.  PipelineBuilder pb = new PipelineBuilder("Test Pipeline", new YamlPipelineConfiguration(yaml));
  6.  BaleenPipeline pipeline = pb.createNewPipeline();
  7.  CollectionReader cr = pipeline.collectionReader();
  8.  assertEquals("uk.gov.dstl.baleen.testing.DummyCollectionReader", cr.getMetaData().getName());
  9.  List<AnalysisEngine> annotators = pipeline.annotators();
  10.  assertEquals(0, annotators.size());
  11. }

代码示例来源：origin: dstl/baleen

  1. @Test
  2.  public void testPause() throws IOException {
  3.   BaleenPipeline bop =
  4.     new BaleenPipeline(
  5.       "Test Name",
  6.       new YamlPipelineConfiguration(),
  7.       new NoOpOrderer(),
  8.       null,
  9.       Collections.emptyList(),
  10.       Collections.emptyList());
  12.   assertFalse(bop.isPaused());
  13.   bop.pause();
  14.   assertTrue(bop.isPaused());
  15.   bop.unpause();
  16.   assertFalse(bop.isPaused());
  17.  }
  18. }

代码示例来源：origin: dstl/baleen

  1. @Test
  2. public void testValid3() throws Exception {
  3.  String yaml = Files.asCharSource(getFile("jobConfig3.yaml"), Charset.defaultCharset()).read();
  4.  JobBuilder jb = new JobBuilder("Test Job", new YamlPipelineConfiguration(yaml));
  5.  BaleenJob job = (BaleenJob) jb.createNewPipeline();
  6.  assertEquals("Test Job", job.getName());
  7.  assertEquals(yaml, job.originalConfig());
  8.  assertEquals(yaml, job.orderedConfig());
  9.  CollectionReader cr = job.collectionReader();
  10.  assertEquals("uk.gov.dstl.baleen.schedules.Other", cr.getMetaData().getName());
  11.  assertEquals("Foo", cr.getConfigParameterValue("key"));
  12.  List<AnalysisEngine> annotators = job.annotators();
  13.  assertEquals(2, annotators.size());
  14.  AnalysisEngine ann0 = annotators.get(0);
  15.  assertEquals("uk.gov.dstl.baleen.testing.DummyTask", ann0.getMetaData().getName());
  16.  assertEquals("Foo", ann0.getConfigParameterValue("key"));
  17.  AnalysisEngine ann1 = annotators.get(1);
  18.  assertEquals("uk.gov.dstl.baleen.testing.DummyTaskParams", ann1.getMetaData().getName());
  19.  assertEquals("Bar", ann1.getConfigParameterValue("key"));
  20.  List<AnalysisEngine> consumers = job.consumers();
  21.  assertEquals(0, consumers.size());
  22. }

内容来源于网络，如有侵权，请联系作者删除！

YamlPipelineConfiguration

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    YamlPipelineConfiguration类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com