/
local.properties
33 lines (26 loc) · 1.47 KB
/
local.properties
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
# == Query ==
FLINK_SQL_QUERY=SELECT event_timestamp, is_valid, order_number from data_stream
FLINK_WATERMARK_INTERVAL_MS=10000
FLINK_WATERMARK_DELAY_MS=0
# == Input Stream ==
STREAMS=[ { "SOURCE_KAFKA_TOPIC_NAMES": "dagger-test-topic-v1", "INPUT_SCHEMA_TABLE": "data_stream", "INPUT_SCHEMA_PROTO_CLASS":"org.raystack.dagger.consumer.TestPrimitiveMessage", "INPUT_SCHEMA_EVENT_TIMESTAMP_FIELD_INDEX": "9", "SOURCE_KAFKA_CONSUMER_CONFIG_BOOTSTRAP_SERVERS": "localhost:9092", "SOURCE_KAFKA_CONSUMER_CONFIG_AUTO_COMMIT_ENABLE": "false", "SOURCE_KAFKA_CONSUMER_CONFIG_AUTO_OFFSET_RESET": "latest", "SOURCE_KAFKA_CONSUMER_CONFIG_GROUP_ID": "dagger-test-topic-cgroup-v1", "SOURCE_KAFKA_NAME": "local-kafka-stream", "SOURCE_DETAILS": [ { "SOURCE_TYPE": "UNBOUNDED", "SOURCE_NAME": "KAFKA_CONSUMER" } ] } ]
# == Preprocessor ==
PROCESSOR_PREPROCESSOR_ENABLE=false
PROCESSOR_PREPROCESSOR_CONFIG={}
# == Postprocessor ==
PROCESSOR_POSTPROCESSOR_ENABLE=false
PROCESSOR_POSTPROCESSOR_CONFIG={}
# == Sink ==
SINK_TYPE=log
# == Stencil ==
SCHEMA_REGISTRY_STENCIL_ENABLE=true
SCHEMA_REGISTRY_STENCIL_URLS=http://127.0.0.1:8000/dagger-descriptors.bin
# == Telemetry ==
METRIC_TELEMETRY_SHUTDOWN_PERIOD_MS=10000
METRIC_TELEMETRY_ENABLE=true
# == Others ==
FUNCTION_FACTORY_CLASSES=FunctionFactory
FLINK_ROWTIME_ATTRIBUTE_NAME=rowtime
# == Python Udf ==
PYTHON_UDF_ENABLE=false
PYTHON_UDF_CONFIG={"PYTHON_FILES":"/path/to/files.zip", "PYTHON_REQUIREMENTS": "requirements.txt", "PYTHON_FN_EXECUTION_BUNDLE_SIZE": "1000"}