public static void run()

in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/RunPipeline.java [21:35]

• 15 lines of code
• 1 McCabe index (conditional complexity)

  public static void run(TemplateOptions options) {
    TableSpec sourceSpec =
        TableSpec.builder()
            .setId(options.getSourceType())
            .setLocation(options.getSourceLocation())
            .setProperties(getNonNull(options.getSourceOptions()))
            .build();
    TableSpec sinkSpec =
        TableSpec.builder()
            .setId(options.getSinkType())
            .setLocation(options.getSinkLocation())
            .setProperties(getNonNull(options.getSinkOptions()))
            .build();
    run(options, sourceSpec, sinkSpec);
  }