Sam Caldwell
|
f8c385e31d
|
cleanup
|
2020-03-10 11:44:24 -04:00 |
|
Sam Caldwell
|
18932662de
|
flink: remove use of dataflow
|
2020-03-10 11:44:24 -04:00 |
|
Sam Caldwell
|
013ce19e68
|
flink: replace a lot of dataflow in job manager with internal events
|
2020-03-10 11:44:23 -04:00 |
|
Sam Caldwell
|
18fdcdeff7
|
untyped flink: use interest as request for jobs
|
2020-03-10 11:44:22 -04:00 |
|
Sam Caldwell
|
90961e57f8
|
untyped flink: unify task-assignment and task-state assertions
|
2020-03-10 11:44:22 -04:00 |
|
Sam Caldwell
|
14db8ce919
|
untyped flink: finish streamlining ids, resolve dataflow issue
|
2020-03-10 11:44:21 -04:00 |
|
Sam Caldwell
|
79277c91d3
|
untyped flink: work on streamlining ids, demonstrating dataflow issue
|
2020-03-10 11:44:21 -04:00 |
|
Sam Caldwell
|
e3d9f93eca
|
untyped flink: fiddle with race in task manager
|
2020-03-10 11:44:21 -04:00 |
|
Sam Caldwell
|
606dd17e08
|
associate task runners with a particular task manager
|
2020-03-10 11:44:21 -04:00 |
|
Sam Caldwell
|
32ebb804fb
|
flink: task runners don't need a status
|
2020-03-10 11:44:20 -04:00 |
|
Sam Caldwell
|
ed7c212561
|
start cleaning up/streamlining flink
|
2020-03-10 11:44:20 -04:00 |
|
Sam Caldwell
|
f9dcad855e
|
examples/flink: implement task delegation roles in terms of abstract
templates
|
2020-03-10 11:44:03 -04:00 |
|
Sam Caldwell
|
f85203ac73
|
examples/flink: small cleanups
|
2019-03-05 10:53:30 -05:00 |
|
Sam Caldwell
|
0da903e438
|
examples/flink: merge task assignment and delegation protocols
|
2019-02-26 15:48:26 -05:00 |
|
Sam Caldwell
|
22bd143025
|
examples/flink: rename map and reduce structs for slightly less overloading on task
|
2019-02-26 13:34:12 -05:00 |
|
Sam Caldwell
|
a6d6ceaa7c
|
examples/flink: tidy up a bit
|
2019-02-26 12:13:37 -05:00 |
|
Sam Caldwell
|
abc8669b74
|
examples/flink: describe the protocol
|
2019-02-26 10:50:00 -05:00 |
|
Sam Caldwell
|
a98ba7baab
|
examples/flink: avoid asking the task manager to do more than it is
capable of
|
2019-02-21 15:10:42 -05:00 |
|
Sam Caldwell
|
702c53f7d1
|
examples/flink: Split lines to words in job runner; trim punctuation on words
|
2019-02-18 16:03:27 -05:00 |
|
Sam Caldwell
|
bb028b1af8
|
examples/flink: create a job from a file
Doesn't handle punctuation properly
|
2019-02-18 15:45:10 -05:00 |
|
Sam Caldwell
|
fb778ab1ee
|
examples/flink: create tasks & jobs from an input string rather than
manually
|
2019-02-18 15:21:24 -05:00 |
|
Sam Caldwell
|
5cb0462ec4
|
examples: adapt Jonathan's flink exceprt to syndicate
|
2019-02-13 15:53:04 -05:00 |