Package org.apache.twill.filesystem

Examples of org.apache.twill.filesystem.LocalLocationFactory

373
374
375
376
377
378
379
380
381
382
383
    return new PrivateModule() {
      @Override
      protected void configure() {
        bind(LocationFactory.class)
          .annotatedWith(Names.named("program.location.factory"))
          .toInstance(new LocalLocationFactory(new File(System.getProperty("user.dir"))));
        bind(ProgramFactory.class).in(Scopes.SINGLETON);
        expose(ProgramFactory.class);
      }
    };
  }
View Full Code Here
114
115
116
117
118
119
120
121
122
123
124
    try {
      Application app;
      try {
        if ("LOCAL".equals(locationFactory)) {
          lf = new LocalLocationFactory();
        } else if ("DISTRIBUTED".equals(locationFactory)) {
          lf = new HDFSLocationFactory(new Configuration());
        } else {
          LOG.error("Unknown location factory specified");
          return -1;
View Full Code Here
181
182
183
184
185
186
187
188
189
190
191
  private void addModule(String moduleName, Class<?> typeClass) throws DatasetManagementException {
    try {
      File tempFile = File.createTempFile(typeClass.getName(), ".jar");
      try {
        Location tempJarPath = createDeploymentJar(typeClass, new LocalLocationFactory().create(tempFile.toURI()));
        client.addModule(moduleName, typeClass.getName(), tempJarPath);
      } finally {
        tempFile.delete();
      }
    } catch (IOException e) {
View Full Code Here
47
48
49
50
51
52
53
54
55
56
57
  @Rule
  public TemporaryFolder tmpDir = new TemporaryFolder();

  @Test
  public void testFindDependencies() throws IOException, ClassNotFoundException {
    Location location = new LocalLocationFactory(tmpDir.newFolder()).create("test.jar");

    // Create a jar file with by tracing dependency
    ApplicationBundler bundler = new ApplicationBundler(ImmutableList.<String>of());
    bundler.createBundle(location, ApplicationBundler.class);
View Full Code Here
111
112
113
114
115
116
117
118
119
120
121
    // Note: It's a little bit hacky based on the uri schema to create the LocationFactory, refactor it later.
    URI appDir = URI.create(System.getenv(EnvKeys.TWILL_APP_DIR));

    try {
      if ("file".equals(appDir.getScheme())) {
        return new LocalLocationFactory().create(appDir);
      }

      if ("hdfs".equals(appDir.getScheme())) {
        if (UserGroupInformation.isSecurityEnabled()) {
          return new HDFSLocationFactory(FileSystem.get(conf)).create(appDir);
View Full Code Here
117
118
119
120
121
122
123
124
125
126
  /**
   * Creates an unstarted instance of {@link org.apache.twill.api.TwillRunnerService}.
   */
  public static final TwillRunnerService createTwillRunnerService(File folder) throws IOException {
    YarnTwillRunnerService runner = new YarnTwillRunnerService(config, zkServer.getConnectionStr() + "/twill",
            new LocalLocationFactory(folder));
    // disable tests stealing focus
    runner.setJVMOptions("-Djava.awt.headless=true");
    return runner;
  }
View Full Code Here
113
114
115
116
117
118
119
120
121
122
  /**
   * Creates an unstarted instance of {@link org.apache.twill.api.TwillRunnerService}.
   */
  public static final TwillRunnerService createTwillRunnerService(File folder) throws IOException {
    YarnTwillRunnerService runner = new YarnTwillRunnerService(config, zkServer.getConnectionStr() + "/twill",
            new LocalLocationFactory(folder));
    // disable tests stealing focus
    runner.setJVMOptions("-Djava.awt.headless=true");
    return runner;
  }
View Full Code Here
102
103
104
105
106
107
108
109
110
111
112
    // Note: It's a little bit hacky based on the uri schema to create the LocationFactory, refactor it later.
    URI appDir = URI.create(System.getenv(EnvKeys.TWILL_APP_DIR));

    try {
      if ("file".equals(appDir.getScheme())) {
        return new LocalLocationFactory().create(appDir);
      }

      if ("hdfs".equals(appDir.getScheme())) {
        if (UserGroupInformation.isSecurityEnabled()) {
          return new HDFSLocationFactory(FileSystem.get(conf)).create(appDir);
View Full Code Here
169
170
171
172
173
174
175
176
      public InputStream getInput() throws IOException {
        return program.getJarLocation().getInputStream();
      }
    }, tempJar);

    final Location jarLocation = new LocalLocationFactory().create(tempJar.toURI());
    return Programs.createWithUnpack(jarLocation, programDir);
  }
View Full Code Here
344
345
346
347
348
349
350
351
352
353
354
    return new PrivateModule() {
      @Override
      protected void configure() {
        bind(LocationFactory.class)
          .annotatedWith(Names.named("program.location.factory"))
          .toInstance(new LocalLocationFactory(new File(System.getProperty("user.dir"))));
        bind(ProgramFactory.class).in(Scopes.SINGLETON);
        expose(ProgramFactory.class);
      }
    };
  }
View Full Code Here
TOP

Related Classes of org.apache.twill.filesystem.LocalLocationFactory

  • co.cask.cdap.app.deploy.SandboxJVM
  • co.cask.cdap.common.guice.LocationRuntimeModule$LocalLocationModule
  • co.cask.cdap.data2.datafabric.dataset.RemoteDatasetFramework
  • co.cask.cdap.internal.app.runtime.distributed.AbstractDistributedProgramRunner
  • co.cask.cdap.internal.app.runtime.distributed.AbstractProgramTwillRunnable
  • co.cask.cdap.internal.app.runtime.distributed.ServiceTwillRunnable
  • co.cask.cdap.test.internal.AppFabricTestHelper
  • co.cask.tigon.flow.DeployClient
  • co.cask.tigon.guice.LocationRuntimeModule$LocalLocationModule
  • co.cask.tigon.internal.app.runtime.distributed.AbstractDistributedProgramRunner
    • Copyright © 2018 www.massapicom. 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.