judy0131
|
cd615ad58e
|
set batchDuration from streamingStop
|
2019-03-01 16:16:25 +08:00 |
|
judy0131
|
c28fee4c1e
|
support kafka streaming
|
2019-02-28 11:00:21 +08:00 |
|
judy0131
|
3d54df81f4
|
support streaming
|
2019-02-20 18:37:23 +08:00 |
|
judy0131
|
dd09d8c6d1
|
fix bug: jdbcRead stop's properties repeat
|
2019-01-30 10:41:28 +08:00 |
|
judy0131
|
081a15663b
|
monitor the throughput of flow
|
2019-01-24 15:32:07 +08:00 |
|
judy0131
|
2ef86d8097
|
iptimize code
|
2019-01-23 14:17:34 +08:00 |
|
judy0131
|
b48ff0bfc2
|
show flow debug data by path
|
2019-01-23 11:27:05 +08:00 |
|
judy0131
|
1fe9f009e1
|
fix bug: when stop flow, the end time do not show
|
2019-01-15 15:23:29 +08:00 |
|
judy0131
|
9cba0f2e6e
|
show dataFrame when job is completed
|
2019-01-14 16:54:22 +08:00 |
|
judy0131
|
212f60479a
|
fix stop flow bug
|
2018-12-14 18:12:21 +08:00 |
|
judy0131
|
04b8992a89
|
fix progress bug
|
2018-12-07 14:03:18 +08:00 |
|
judy0131
|
5914c981a9
|
fix progress bug
|
2018-12-05 18:33:45 +08:00 |
|
judy0131
|
8b109c6902
|
fix bug: remove hive-site.xml core-site.xml
|
2018-11-30 17:07:19 +08:00 |
|
judy0131
|
972f8af248
|
fix flow progress bug
|
2018-11-28 18:17:39 +08:00 |
|
judy0131
|
420477fe45
|
add progress in flow info
|
2018-11-28 16:52:58 +08:00 |
|
judy0131
|
808a8e1693
|
fix checkpoint bug
|
2018-11-28 15:02:52 +08:00 |
|
judy0131
|
7449cbf1dc
|
fix bug: get flow progress using checkpoint
|
2018-11-21 11:26:45 +08:00 |
|
judy0131
|
dd11c444a2
|
1.implement checkpoint
|
2018-11-20 16:46:47 +08:00 |
|
judy0131
|
82c64aabae
|
add flow name in flowImpl
|
2018-11-06 17:07:13 +08:00 |
|
judy0131
|
a4badc9703
|
1.modify getFlowProgress api
2.add maven-install-plugin to install the databricks file
|
2018-11-06 13:55:28 +08:00 |
|
judy0131
|
165965fda4
|
modify log
|
2018-10-25 14:01:49 +08:00 |
|
judy0131
|
6b6a1588ec
|
1.add h2 port
2.fix bug: multi server
|
2018-10-25 13:18:14 +08:00 |
|
judy0131
|
c6db0d1acb
|
add getFlowProgress and getFlowLog API
|
2018-10-24 18:13:40 +08:00 |
|
judy0131
|
80e3e874d6
|
monitor flow info and stop info
|
2018-10-24 17:33:46 +08:00 |
|
judy0131
|
7ebaba5df2
|
add common group and csv group's getPropertyDescriptor api
|
2018-10-12 14:01:07 +08:00 |
|
judy0131
|
2ab05fccdd
|
1.modify piflow module,delete piflow-conf 2.deploy jar on server
|
2018-09-05 17:54:21 +08:00 |
|
judy0131
|
b60af904ff
|
add piflow configure module
|
2018-07-10 17:13:27 +08:00 |
bluejoe2008@gmail.com
|
682837624f
|
Path.via()
|
2018-07-05 14:46:37 +08:00 |
|
bluejoe2008@gmail.com
|
a95cc77c20
|
rename bundleIn to inport
|
2018-07-05 14:18:47 +08:00 |
|
bluejoe2008@gmail.com
|
4da512ba7f
|
rename bundleIn to inport
|
2018-07-05 09:44:21 +08:00 |
|
bluejoe2008@gmail.com
|
3f21fdca74
|
process group
|
2018-06-28 09:50:48 +08:00 |
|
bluejoe2008@gmail.com
|
fccf7a9717
|
process group
|
2018-06-27 18:40:31 +08:00 |
|
bluejoe2008@gmail.com
|
c557af090c
|
process group
|
2018-06-27 16:42:50 +08:00 |
|
bluejoe2008@gmail.com
|
bcb49511a0
|
rename flowexecution to process
|
2018-06-27 11:50:58 +08:00 |
|
bluejoe2008@gmail.com
|
5554d4a64e
|
rename flowexecution to process
|
2018-06-27 11:42:11 +08:00 |
|
bluejoe2008@gmail.com
|
f048079f9d
|
awaitTermination() & stop()
|
2018-06-27 10:28:54 +08:00 |
|
bluejoe2008@gmail.com
|
9a20653ef1
|
awaitTermination() & stop()
|
2018-06-27 10:14:46 +08:00 |
|
bluejoe2008@gmail.com
|
b010843676
|
awaitTermination() & stop()
|
2018-06-26 18:33:32 +08:00 |
|
bluejoe2008@gmail.com
|
d734a6ec08
|
script function accepts 1+ arguments
|
2018-06-26 15:40:24 +08:00 |
|
bluejoe2008@gmail.com
|
877b45c81b
|
Path.of()
|
2018-06-26 14:44:08 +08:00 |
|
bluejoe2008@gmail.com
|
168a23bb5a
|
Path.of()
|
2018-06-26 11:11:09 +08:00 |
|
bluejoe2008@gmail.com
|
e6a0886aef
|
create conf module
|
2018-06-26 10:33:02 +08:00 |
|
bluejoe2008@gmail.com
|
bb58256a04
|
create conf module
|
2018-06-26 10:31:57 +08:00 |