Examples of execute()

Examples of com.netflix.priam.backup.IncrementalBackup.execute()

30
31
32
33
34
35
36
37
38
39
40
        {
            Application.initialize();
            IncrementalBackup backuper = Application.getInjector().getInstance(IncrementalBackup.class);
            try
            {
                backuper.execute();
            } catch (Exception e)
            {
                logger.error("Unable to backup: ", e);
            }
        } finally
View Full Code Here

Examples of com.netflix.priam.backup.SnapshotBackup.execute()

30
31
32
33
34
35
36
37
38
39
40
        {
            Application.initialize();
            SnapshotBackup backuper = Application.getInjector().getInstance(SnapshotBackup.class);
            try
            {
                backuper.execute();
            } catch (Exception e)
            {
                logger.error("Unable to backup: ", e);
            }
        } finally
View Full Code Here

Examples of com.netflix.zeno.util.SimultaneousExecutor.execute()

361
362
363
364
365
366
367
368
369
370
371
        fill.ensureCapacity(maxOrdinal() + 1);

        for(int i=0;i<numThreads;i++) {
            final int threadNumber = i;
            executor.execute(new Runnable() {
                @Override
                public void run() {
                    FastBlobDeserializationRecord rec = new FastBlobDeserializationRecord(fill.getSchema(), byteData.getUnderlyingArray());
                    for(int i=threadNumber;i<pointersAndOrdinals.length();i += numThreads) {
                        long pointerAndOrdinal = pointersAndOrdinals.get(i);
View Full Code Here

Examples of com.ning.http.client.AsyncHttpClient.BoundRequestBuilder.execute()

172
173
174
175
176
177
178
179
180
181
182
            sender = getSender();

            // Construct and submit NING Request
            BoundRequestBuilder request = createRequest();
            // String targetUrl = request.build().getUrl();
            request.execute(new HttpAsyncHandler(this));

            timeoutDuration = Duration
                .create(VarUtils.ACTOR_MAX_OPERATION_TIME_SECONDS_DEFAULT,
                    TimeUnit.SECONDS);
View Full Code Here

Examples of com.nykredit.kundeservice.data.sql.SqlQuery.execute()

50
51
52
53
54
55
56
57
58
59
60
               "KS_DRIFT.WEBDESK_DEPARTMENT";

    SqlQuery query = new SqlQuery(conn, sql);

    try {
      query.execute();
     
      while(query.next())
        departments.add(new WebdeskDepartment(query.getInteger("ID"), query.getString("DEPARTMENT")));
    } catch (DopeException e) {
      throw new OperationAbortedException(e, "Error during load of webdesk departments.", "Der skete en fejl ved indl�sning af webdesk departments.");
View Full Code Here

Examples of com.openbravo.data.loader.Transaction.execute()

164
165
166
167
168
169
170
171
172
173
174
                }

                return null;
            }
        };
        t.execute();
    }
       
   
    public void syncProductsBefore() throws BasicException {
        new StaticSentence(s, "DELETE FROM PRODUCTS_CAT").exec();
View Full Code Here

Examples of com.opengamma.engine.exec.DependencyGraphExecutor.execute()

167
168
169
170
171
172
173
174
175
176
177
    final DependencyGraphExecutor executor = getCycle().getViewProcessContext().getDependencyGraphExecutorFactory().createExecutor(getCycle());
    for (final String calcConfigurationName : getCycle().getAllCalculationConfigurationNames()) {
      s_logger.info("Executing plans for calculation configuration {}", calcConfigurationName);
      final DependencyGraph depGraph = getCycle().createExecutableDependencyGraph(calcConfigurationName);
      s_logger.info("Submitting {} for execution by {}", depGraph, executor);
      final DependencyGraphExecutionFuture future = executor.execute(depGraph);
      _executing.put(calcConfigurationName, new ExecutingCalculationConfiguration(getCycle(), depGraph, future));
      future.setListener(this);
    }
    try {
      while (!_executing.isEmpty()) {
View Full Code Here

Examples of com.opengamma.engine.function.FunctionInvoker.execute()

801
802
803
804
805
806
807
808
809
810
811
    }
    // Execute
    statistics.beginInvocation();
    Set<ComputedValue> result;
    try {
      result = invoker.execute(getFunctionExecutionContext(), functionInputs, target, plat2290(outputs));
    } catch (final AsynchronousExecution e) {
      s_logger.debug("Asynchronous execution of {} at {}", jobItem, _nodeId);
      final AsynchronousOperation<Deferred<Void>> async = deferredOperation();
      e.setResultListener(new ResultListener<Set<ComputedValue>>() {
        @Override
View Full Code Here

Examples of com.opengamma.integration.tool.portfolio.PortfolioLoader.execute()

320
321
322
323
324
325
326
327
328
329
330
      URL resource = ExampleEquityPortfolioLoader.class.getResource("equityOptions.zip");
      final String file = unpackJar(resource);
      final PortfolioLoader equityOptionLoader = new PortfolioLoader(getToolContext(), EQUITY_OPTION_PORTFOLIO_NAME, null,
              file, true,
              true, true, false, true, false, null);
      equityOptionLoader.execute();
      log.done();
    } catch (final RuntimeException t) {
      log.fail(t);
    }
  }
View Full Code Here

Examples of com.opengamma.util.db.tool.DbCreateOperation.execute()

114
115
116
117
118
119
120
121
122
123
124
    dbToolContext.setCatalog(catalog);
    dbToolContext.setSchemaNames(ImmutableSet.of(schemaName));
    if (actualSchemaVersion == null) {
      // Assume empty database, so attempt to create tables
      DbCreateOperation createOperation = new DbCreateOperation(dbToolContext, true, null, false);
      createOperation.execute();
    } else if (actualSchemaVersion < expectedSchemaVersion) {
      // Upgrade from expected to actual
      DbUpgradeOperation upgradeOperation = new DbUpgradeOperation(dbToolContext, true, null);
      upgradeOperation.execute();
    } else if (expectedSchemaVersion > actualSchemaVersion) {
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.