@Test public void testTDJobRequestParamsWithEngineVersion() throws Exception { Path projectPath = Paths.get("").normalize().toAbsolutePath(); Config config = newConfig() .set("database", "testdb") .set("query", "select 1") .set("engine", "hive") .set("engine_version", "stable"); when(op.submitNewJobWithRetry(any(TDJobRequest.class))).thenReturn(""); when(op.getDatabase()).thenReturn("testdb"); TDJobRequest jobRequest = testTDJobRequestParams(projectPath, config); assertEquals("testdb", jobRequest.getDatabase()); assertEquals("select 1", jobRequest.getQuery()); assertEquals("hive", jobRequest.getType().toString()); assertTrue(jobRequest.getEngineVersion().isPresent()); assertEquals("stable", jobRequest.getEngineVersion().get().toString()); }
public String getType() { return "td_wait"; }
TdWaitOperatorFactory extends AbstractWaitOperatorFactory implements OperatorFactory { public String getType() { return "td_wait"; } }
TdWaitOperatorFactory extends AbstractWaitOperatorFactory implements OperatorFactory { public String getType() { return "td_wait"; } @Inject  TdWaitOperatorFactory(TemplateEngine templateEngine, Config systemConfig, @Environment Map<String, String> env); }
TdWaitOperatorFactory extends AbstractWaitOperatorFactory implements OperatorFactory { public String getType() { return "td_wait"; } @Inject  TdWaitOperatorFactory(TemplateEngine templateEngine, Config systemConfig, @Environment Map<String, String> env); String getType(); @Override Operator newOperator(OperatorContext context); }
TdWaitOperatorFactory extends AbstractWaitOperatorFactory implements OperatorFactory { public String getType() { return "td_wait"; } @Inject  TdWaitOperatorFactory(TemplateEngine templateEngine, Config systemConfig, @Environment Map<String, String> env); String getType(); @Override Operator newOperator(OperatorContext context);  }