@Test public void testEmptyBqDdl2() { Config config = newConfig(); config.set("_command", ""); config.set("create_datasets", ImmutableList.of()); config.set("empty_datasets", ImmutableList.of()); config.set("delete_datasets", ImmutableList.of()); config.set("create_tables", ImmutableList.of()); config.set("empty_tables", ImmutableList.of()); config.set("delete_tables", ImmutableList.of()); when(taskRequest.getConfig()).thenReturn(config); Operator operator = factory.newOperator(operatorContext); operator.run(); verify(bqClient).close(); verifyNoMoreInteractions(bqClient); }
@Override public Operator newOperator(OperatorContext context) { return new BqDdlOperator(context); }
BqDdlOperatorFactory implements OperatorFactory { @Override public Operator newOperator(OperatorContext context) { return new BqDdlOperator(context); } }
BqDdlOperatorFactory implements OperatorFactory { @Override public Operator newOperator(OperatorContext context) { return new BqDdlOperator(context); } @Inject  BqDdlOperatorFactory(
            ObjectMapper objectMapper,
            BqClient.Factory clientFactory,
            GcpCredentialProvider credentialProvider); }
BqDdlOperatorFactory implements OperatorFactory { @Override public Operator newOperator(OperatorContext context) { return new BqDdlOperator(context); } @Inject  BqDdlOperatorFactory(
            ObjectMapper objectMapper,
            BqClient.Factory clientFactory,
            GcpCredentialProvider credentialProvider); String getType(); @Override Operator newOperator(OperatorContext context); }
BqDdlOperatorFactory implements OperatorFactory { @Override public Operator newOperator(OperatorContext context) { return new BqDdlOperator(context); } @Inject  BqDdlOperatorFactory(
            ObjectMapper objectMapper,
            BqClient.Factory clientFactory,
            GcpCredentialProvider credentialProvider); String getType(); @Override Operator newOperator(OperatorContext context);  }