同步操作将从 ideal(harbby)/sylph 强制同步,此操作会覆盖自 Fork 仓库以来所做的任何修改,且无法恢复!!!
确定后同步将在后台操作,完成时将刷新页面,请耐心等待。
The sylph is stream and batch Job management platform. The sylph core idea is to build distributed applications through workflow descriptions. Support for
create source table topic1(
key varchar,
value varchar,
event_time bigint
) with (
type = 'ideal.sylph.plugins.flink.source.TestSource'
);
-- Define the data stream output location
create sink table print_table_sink(
key varchar,
cnt long,
window_time varchar
) with (
type = 'ideal.sylph.plugins.flink.sink.PrintSink', -- print console
other = 'demo001'
);
-- Define WATERMARK, usually you should parse the event_time field from the kafka message
create view TABLE foo
WATERMARK event_time FOR rowtime BY ROWMAX_OFFSET(5000) --event_time Generate time for your real data
AS
with tb1 as (select * from topic1) --Usually parsing kafka message here
select * from tb1;
-- Describe the data flow calculation process
insert into print_table_sink
with tb2 as (
select key,
count(1),
cast(TUMBLE_START(rowtime,INTERVAL '5' SECOND) as varchar)|| '-->'
|| cast(TUMBLE_END(rowtime,INTERVAL '5' SECOND) as varchar) AS window_time
from foo where key is not null
group by key,TUMBLE(rowtime,INTERVAL '5' SECOND)
) select * from tb2
The registration of the custom function is consistent with the hive
create function json_parser as 'ideal.sylph.runner.flink.udf.JsonParser';
Support flink-stream
spark-streaming
spark-structured-streaming(spark2.2x)
sylph builds use Gradle and requires Java 8.
# Build and install distributions
./gradlew clean assemble
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:
We need more power to improve the view layer. If you are interested, you can contact me by email.
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。