fake-to-starrocks.conf

#
# Licensed to the Apache Software Foundation (ASF) under one or more
# contributor license agreements.  See the NOTICE file distributed with
# this work for additional information regarding copyright ownership.
# The ASF licenses this file to You under the Apache License, Version 2.0
# (the "License"); you may not use this file except in compliance with
# the License.  You may obtain a copy of the License at
#
#    http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
#

env {
  parallelism = 1
  job.mode = "BATCH"
}

source {
  FakeSource {
    parallelism = 1
    plugin_output = "fake"
    row.num = 100
    schema {
        table = "FakeTable"
        columns = [
           {
              name = id
              type = bigint
              nullable = false
              defaultValue = 0
           },
           {
              name = c_string
              type = string
              nullable = true
           },
           {
              name = c_boolean
              type = boolean
              nullable = true
           },
           {
              name = c_tinyint
              type = tinyint
              nullable = true
           },
           {
              name = c_int
              type = int
              nullable = true
           },
           {
              name = c_bigint
              type = bigint
              nullable = true
           },
           {
              name = c_float
              type = float
              nullable = true
           },
          {
             name = c_double
             type = double
             nullable = true
          },
          {
             name = c_decimal
             type = "decimal(2, 1)"
             nullable = true
          },
          {
             name = c_date
             type = date
             nullable = true
          }
       ]
      }
    }
}

transform {
}

sink {
  StarRocks {
    plugin_input = "fake"
    nodeUrls = ["starrocks_e2e:8030"]
    username = root
    password = ""
    database = "test"
    table = "fake_table_sink"
    batch_max_rows = 100
    max_retries = 3
    base-url="jdbc:mysql://starrocks_e2e:9030/test"
    starrocks.config = {
      format = "JSON"
      strip_outer_array = true
    }
  }
}