public static void main()

in java/dataflow-connector-examples/src/main/java/com/google/cloud/bigtable/dataflow/example/HelloWorldWrite.java [97:125]

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

  public static void main(String[] args) {
    // [START bigtable_dataflow_connector_create_pipeline]
    CloudBigtableOptions options =
        PipelineOptionsFactory.fromArgs(args).withValidation().as(CloudBigtableOptions.class);
    Pipeline p = Pipeline.create(options);
    // [END bigtable_dataflow_connector_create_pipeline]

    String PROJECT_ID = options.getBigtableProjectId();
    String INSTANCE_ID = options.getBigtableInstanceId();
    String TABLE_ID = options.getBigtableTableId();

    // [START bigtable_dataflow_connector_config]
    CloudBigtableTableConfiguration config =
        new CloudBigtableTableConfiguration.Builder()
            .withProjectId(PROJECT_ID)
            .withInstanceId(INSTANCE_ID)
            .withTableId(TABLE_ID)
            .build();
    // [END bigtable_dataflow_connector_config]

    // [START bigtable_dataflow_connector_write_helloworld]
    p
        .apply(Create.of("Hello", "World"))
        .apply(ParDo.of(MUTATION_TRANSFORM))
        .apply(CloudBigtableIO.writeToTable(config));
    // [END bigtable_dataflow_connector_write_helloworld]

    p.run().waitUntilFinish();
  }