Examples of CopyEntry

org.springframework.yarn.fs.LocalResourcesFactoryBean.CopyEntry

Examples of org.springframework.yarn.fs.LocalResourcesFactoryBean.CopyEntry

    String dir = "/DefaultResourceLocalizerTests-testSimpleCopy";
    LocalResourcesFactoryBean factory = new LocalResourcesFactoryBean();
    factory.setConfiguration(configuration);


    List<CopyEntry> copyEntries = new ArrayList<CopyEntry>();
    CopyEntry entry = new CopyEntry("classpath:/test-site-1.xml", dir, false);
    copyEntries.add(entry);
    factory.setCopyEntries(copyEntries);
    factory.setHdfsEntries(new ArrayList<LocalResourcesFactoryBean.TransferEntry>());
    factory.afterPropertiesSet();

View Full Code Here

Examples of org.springframework.yarn.fs.LocalResourcesFactoryBean.CopyEntry

    String dir = "DefaultResourceLocalizerTests-testSimpleCopyHomeStaging";
    LocalResourcesFactoryBean factory = new LocalResourcesFactoryBean();
    factory.setConfiguration(configuration);


    List<CopyEntry> copyEntries = new ArrayList<CopyEntry>();
    CopyEntry entry = new CopyEntry("classpath:/test-site-1.xml", null, true);
    copyEntries.add(entry);
    factory.setCopyEntries(copyEntries);
    factory.setHdfsEntries(new ArrayList<LocalResourcesFactoryBean.TransferEntry>());
    factory.afterPropertiesSet();

View Full Code Here

Examples of org.springframework.yarn.fs.LocalResourcesFactoryBean.CopyEntry

    String dir = "/DefaultResourceLocalizerTests-testSimpleDistribute";
    LocalResourcesFactoryBean factory = new LocalResourcesFactoryBean();
    factory.setConfiguration(configuration);


    List<CopyEntry> copyEntries = new ArrayList<CopyEntry>();
    CopyEntry entry = new CopyEntry("classpath:/test-site-1.xml", dir, false);
    copyEntries.add(entry);
    factory.setCopyEntries(copyEntries);


    List<TransferEntry> transferEntries = new ArrayList<TransferEntry>();
    TransferEntry tEntry = new TransferEntry(null, null, dir + "/test-site-1.xml", false);

View Full Code Here

Examples of org.springframework.yarn.fs.LocalResourcesFactoryBean.CopyEntry

  public void testDistributeGlobalCustomStaging() throws Exception {
    LocalResourcesFactoryBean factory = new LocalResourcesFactoryBean();
    factory.setConfiguration(configuration);


    List<CopyEntry> copyEntries = new ArrayList<CopyEntry>();
    CopyEntry entry = new CopyEntry("classpath:/test-site-1.xml", null, true);
    copyEntries.add(entry);
    factory.setCopyEntries(copyEntries);


    List<TransferEntry> transferEntries = new ArrayList<TransferEntry>();
    TransferEntry tEntry = new TransferEntry(null, null, "/test-site-1.xml", true);

View Full Code Here

Examples of org.springframework.yarn.fs.LocalResourcesFactoryBean.CopyEntry

  public void testDistributeGlobalDefaultStaging() throws Exception {
    LocalResourcesFactoryBean factory = new LocalResourcesFactoryBean();
    factory.setConfiguration(configuration);


    List<CopyEntry> copyEntries = new ArrayList<CopyEntry>();
    CopyEntry entry = new CopyEntry("classpath:/test-site-1.xml", null, true);
    copyEntries.add(entry);
    factory.setCopyEntries(copyEntries);


    List<TransferEntry> transferEntries = new ArrayList<TransferEntry>();
    TransferEntry tEntry = new TransferEntry(null, null, "/test-site-1.xml", true);

View Full Code Here

Examples of org.springframework.yarn.fs.LocalResourcesFactoryBean.CopyEntry

    String dir = "DefaultResourceLocalizerTests-testDistributeHomeStaging";
    LocalResourcesFactoryBean factory = new LocalResourcesFactoryBean();
    factory.setConfiguration(configuration);


    List<CopyEntry> copyEntries = new ArrayList<CopyEntry>();
    CopyEntry entry = new CopyEntry("classpath:/test-site-1.xml", null, true);
    copyEntries.add(entry);
    factory.setCopyEntries(copyEntries);


    List<TransferEntry> transferEntries = new ArrayList<TransferEntry>();
    TransferEntry tEntry = new TransferEntry(null, null, "/test-site-1.xml", true);

View Full Code Here

Examples of org.springframework.yarn.fs.LocalResourcesFactoryBean.CopyEntry

    }
  }


  @Override
  public LocalResourcesCopyConfigurer copy(String src, String dest, boolean staging) {
    copyEntries.add(new CopyEntry(src, dest, staging));
    return this;
  }

View Full Code Here

Examples of org.springframework.yarn.fs.LocalResourcesFactoryBean.CopyEntry


  @Override
  public LocalResourcesCopyConfigurer copy(String[] srcs, String dest, boolean staging) {
    if (!ObjectUtils.isEmpty(srcs)) {
      for (String src : srcs) {
        copyEntries.add(new CopyEntry(src, dest, staging));
      }
    }


    return this;
  }

View Full Code Here

Examples of org.springframework.yarn.fs.LocalResourcesFactoryBean.CopyEntry

    public ConfiguredCopyEntry destination(String destination) {
      this.destination = destination;
      return this;
    }
    public LocalResourcesCopyConfigurer staging(boolean staging) {
      copyEntries.add(new CopyEntry(source, destination, staging));
      return DefaultLocalResourcesCopyConfigurer.this;
    }

View Full Code Here

Examples of org.springframework.yarn.fs.LocalResourcesFactoryBean.CopyEntry

    assertNotNull(copyEntries);
    assertThat(copyEntries.size(), is(2));


    Iterator<CopyEntry> iterator = copyEntries.iterator();


    CopyEntry copyEntry1 = iterator.next();
    String copyEntrySrc1 = TestUtils.readField("src", copyEntry1);
    String copyEntryDest1 = TestUtils.readField("dest", copyEntry1);
    Boolean copyEntryStaging1 = TestUtils.readField("staging", copyEntry1);
    assertThat(copyEntrySrc1, is("foo.jar"));
    assertThat(copyEntryDest1, is("/tmp"));
    assertThat(copyEntryStaging1, is(true));


    CopyEntry copyEntry2 = iterator.next();
    String copyEntrySrc2 = TestUtils.readField("src", copyEntry2);
    String copyEntryDest2 = TestUtils.readField("dest", copyEntry2);
    Boolean copyEntryStaging2 = TestUtils.readField("staging", copyEntry2);
    assertThat(copyEntrySrc2, is("foo2.jar"));
    assertThat(copyEntryDest2, is("/tmp"));

View Full Code Here

TOP

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.