env {
  parallelism = 2
  job.mode = "BATCH"
}
source {
  FakeSource {
    row.num = 16
    schema = {
      fields {
        c_map = "map<string, string>"
      }
    }
    result_table_name = "fake"
  }
}

transform {
  Sql {
    plugin_input = "fake"
    plugin_output = "fake1"
    query = "select * from fake"
  }
    Sql {
      plugin_input = "fake1"
      plugin_output = "fake2"
      query = "select * from fake1"
    }
        Sql {
          plugin_input = "fake2"
          plugin_output = "fake3"
          query = "select * from fake2"
        }
}

sink {
  Console {
  plugin_input = "fake3"
  log.print.data = true
  log.print.delay.ms = 10000
  }
}