blob: c74e457dc8d223d3b354123e97f9f2434380df08 [file] [log] [blame]
################################################################################
# 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.
################################################################################
#==============================================================================
# TEST ENVIRONMENT FILE
# General purpose default environment file.
#==============================================================================
# this file has variables that can be filled with content by replacing $VAR_XXX
tables:
- name: TableNumber1
type: source-table
$VAR_UPDATE_MODE
schema:
- name: IntegerField1
type: INT
- name: StringField1
type: VARCHAR
connector:
type: filesystem
path: "$VAR_SOURCE_PATH1"
format:
type: csv
fields:
- name: IntegerField1
type: INT
- name: StringField1
type: VARCHAR
line-delimiter: "\n"
comment-prefix: "#"
- name: TestView1
type: view
query: SELECT scalarUDF(IntegerField1) FROM TableNumber1
- name: TableNumber2
# Test backwards compatibility ("source" -> "source-table")
type: source
$VAR_UPDATE_MODE
schema:
- name: IntegerField2
type: INT
- name: StringField2
type: VARCHAR
connector:
type: filesystem
path: "$VAR_SOURCE_PATH2"
format:
type: csv
fields:
- name: IntegerField2
type: INT
- name: StringField2
type: VARCHAR
line-delimiter: "\n"
comment-prefix: "#"
- name: TableSourceSink
type: both
$VAR_UPDATE_MODE
schema:
- name: BooleanField
type: BOOLEAN
- name: StringField
type: VARCHAR
connector:
type: filesystem
path: "$VAR_SOURCE_SINK_PATH"
format:
type: csv
fields:
- name: BooleanField
type: BOOLEAN
- name: StringField
type: VARCHAR
line-delimiter: "\n"
comment-prefix: "#"
- name: TestView2
type: view
query: SELECT * FROM TestView1
functions:
- name: scalarUDF
from: class
class: org.apache.flink.table.client.gateway.utils.UserDefinedFunctions$ScalarUDF
constructor:
- 5
- name: aggregateUDF
from: class
class: org.apache.flink.table.client.gateway.utils.UserDefinedFunctions$AggregateUDF
constructor:
- StarryName
- false
- class: java.lang.Integer
constructor:
- class: java.lang.String
constructor:
- type: VARCHAR
value: 3
- name: tableUDF
from: class
class: org.apache.flink.table.client.gateway.utils.UserDefinedFunctions$TableUDF
constructor:
- type: LONG
value: 5
execution:
type: "$VAR_EXECUTION_TYPE"
time-characteristic: event-time
periodic-watermarks-interval: 99
parallelism: 1
max-parallelism: 16
min-idle-state-retention: 0
max-idle-state-retention: 0
result-mode: "$VAR_RESULT_MODE"
max-table-result-rows: "$VAR_MAX_ROWS"
restart-strategy:
type: failure-rate
max-failures-per-interval: 10
failure-rate-interval: 99000
delay: 1000
deployment:
response-timeout: 5000