Welcome to Sylph !
Sylph is Streaming Job Manager.
Sylph uses SQL Query to describe calculations and bind multiple source(input)/sink(output) to visually develop and deploy streaming applications.
Through Web IDE makes it easy to develop, deploy, monitor streaming applications and analyze streaming application behavior at any time.
Sylph has rich source/sink support and flexible extensions to visually develop and deploy stream analysis applications and visualized streaming application lifecycle management.
The Sylph core is to build distributed applications through workflow descriptions. Support for
Copyright (C) 2018 The Sylph Authors Licensed 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.
create function get_json_object as 'com.github.harbby.sylph.runner.flink.runtime.UDFJson'; create source table topic1( _topic varchar, _key varchar, _partition integer, _offset bigint, _message varchar, ip varchar extend '$.conntent.ip', -- json path event_time varchar extend '$.conntent.event_time' -- json path ) with ( type = 'kafka08', kafka_topic = 'event_topic', auto.offset.reset = latest, kafka_broker = 'localhost:9092', kafka_group_id = 'test1', zookeeper.connect = 'localhost:2181' ); -- 定义数据流输出位置 create sink table event_log( key varchar, user_id varchar, offset bigint ) with ( type = 'kudu', kudu.hosts = 'localhost:7051', kudu.tableName = 'impala::test_kudu.log_events', kudu.mode = 'INSERT', batchSize = 5000 ); insert into event_log select _key,get_json_object(_message, 'user_id') as user_id,_offset from topic1
The registration of the custom function is consistent with the hive
create function get_json_object as 'com.github.harbby.sylph.runner.flink.runtime.UDFJson';
sylph builds use Gradle and requires Java 8.
Also if you want read a chinese deploy docs,中文部署文档 may can help you.
# Build and install distributions ./gradlew clean assemble dist
After building Sylph for the first time, you can load the project into your IDE and run the server. Me recommend using IntelliJ IDEA.
After opening the project in IntelliJ, double check that the Java SDK is properly configured for the project:
Sylph comes with sample configuration that should work out-of-the-box for development. Use the following options to create a run configuration:
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容，可点击提交进行申诉，我们将尽快为您处理。