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
- Spark-Streaming (Spark1.x)
- Structured-Streaming (Spark2.x)
- Flink Streaming
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 topic1The 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:
- Open the File menu and select Project Structure
- In the SDKs section, ensure that a 1.8 JDK is selected (create one if none exist)
- In the Project section, ensure the Project language level is set to 8.0 as Sylph makes use of several Java 8 language features
- HADOOP_HOME(2.6.x+) SPARK_HOME(2.4.x+) FLINK_HOME(1.7.x+)
Sylph comes with sample configuration that should work out-of-the-box for development. Use the following options to create a run configuration:
- Main Class: com.github.harbby.sylph.main.SylphMaster
- VM Options: -Dconfig=etc/sylph/sylph.properties -Dlogging.config=etc/sylph/logback.xml
- ENV Options: FLINK_HOME= HADOOP_CONF_DIR=$HADOOP_HOME/etc/hadoop
- Working directory: sylph-dist/build
- Use classpath of module: sylph-main
- [email protected] - For discussions about code, design and features
- [email protected] - For discussions about code, design and features
- [email protected] - For discussions about code, design and features
- Send message to Google Group
- Add QQ Group: 438625067
![dependabot[bot] avatar](https://avatars.githubusercontent.com/in/29110?v=4 "dependabot[bot]")
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent