Google Git
Sign in
apache / incubator-retired-s4 / HEAD
  1. 403162e S4-22 automating tests by Matthieu Morel · 12 years ago
  2. 7eb4882 S4-24 handle interrupt in initial application deployment by Matthieu Morel · 12 years ago
  3. 7382fc8 S4-24 dynamic app deployment by Matthieu Morel · 12 years ago
  4. 25c379f S4-36 : CommTests should use ZkBasedClusterManagement by Karthik Kambatla · 12 years ago
  5. 111959d s4-33:s4.fixtures refactored across s4-comm and s4-core by Karthik Kambatla · 12 years ago
  6. 8b642d1 renamed netty to tcp by Karthik Kambatla · 12 years ago
  7. e228a8a Implemented GenericKeyFinder to specify event fields of primitive types as strings OR event attribute keys as strings. Supported in the std and fluent APIs. by Leo Neumeyer · 12 years ago
  8. 5a173e7 Changed initialization code in PE. Moved threadsafe check to init proto (needs more debugging). Found bug in init trigger, should copy trigger map for each new PE instance. Added close() method to receiverbut comm layer does nott shutdown gracefully. Needs more work. by Leo Neumeyer · 12 years ago
  9. 1804c47 Fixed and cleaned up the original counter example. by Leo Neumeyer · 12 years ago
  10. f617192 Fluent API close to complete. New counter example using the fluent API. by Leo Neumeyer · 12 years ago
  11. c906017 Removed experimental test appmaker package, replaced by test fluent. by Leo Neumeyer · 12 years ago
  12. a6e5cbd Removed experimental appmaker package, replaced by fluent. by Leo Neumeyer · 12 years ago
  13. 21ff6dc Functional fluent API but not tested. by Leo Neumeyer · 12 years ago
  14. 5903890 Fluent API to build S4 apps. by Leo Neumeyer · 12 years ago
  15. fb61d6d Experiment with builder pattern. by Leo Neumeyer · 12 years ago
  16. d6e3684 Added data structures to save ap graph and added toString() to print the app graph. by Leo Neumeyer · 12 years ago
  17. b8cea4a First commit. by Leo Neumeyer · 12 years ago
  18. 701a83c Made Event constructors public. by Leo Neumeyer · 12 years ago
  19. 12d1ccb Added arbitrary attributes to Event. Event no longer abstract. by Leo Neumeyer · 12 years ago
  20. 5b6fae2 Added getStrems() to EventSource. by Leo Neumeyer · 12 years ago
  21. edaa346 Cleaned up some left-over comments in NettyEmitter by Karthik Kambatla · 12 years ago
  22. 2f8051f Maintain messageQueue for each partition in NettyEmitter to tolerate network glitches by Karthik Kambatla · 12 years ago
  23. 90f68b4 renamed test packages by Matthieu Morel · 12 years ago
  24. 502b81e make sure each test runs in a new JVM by Matthieu Morel · 12 years ago
  25. c287c85 comm layer improvements by Matthieu Morel · 12 years ago
  26. d6450a4 comm layer improvements by Matthieu Morel · 12 years ago
  27. df927d2 junit 4 + code formatting by Matthieu Morel · 12 years ago
  28. bba15f2 Merge pull request #9 from kambatla/master by Leo Neumeyer · 12 years ago
  29. 5311f8d working TCP and UDP Tests by Karthik Kambatla · 12 years ago
  30. 5a69991 Merge branch 'master' of git://github.com/leoneu/s4-piper by Karthik Kambatla · 12 years ago
  31. 490982c Added gradlew. by Leo Neumeyer · 12 years ago
  32. 208426c modified s4-comm tests to use junit4; UDPTest not working yet by Karthik Kambatla · 12 years ago
  33. 31b5d22 fast forward by Leo Neumeyer · 12 years ago
  34. 48f5c83 Moved server configuration to Module and moved sender/receiver outside the apps loop. by Leo Neumeyer · 12 years ago
  35. 4c7060a resolve test classes directory at runtime by Matthieu Morel · 12 years ago
  36. c20324f moved server config to Module, moved sender/receiver out of apps loop. by Leo Neumeyer · 12 years ago
  37. 88c4a6d added formatting and coding standards by Matthieu Morel · 12 years ago
  38. 29b00ef added classloading of generated classes by Matthieu Morel · 12 years ago
  39. a6b382d Read MANIFEST main attributes, get teh S4 app name attribute and create a new instance. by Leo Neumeyer · 12 years ago
  40. c01da3b Merge pull request #7 from kambatla/master by Leo Neumeyer · 13 years ago
  41. 0d11197 Working delivery tests for UDP and Netty by Karthik Kambatla · 13 years ago
  42. 92f3252 Modified comm tests to conform to the testing norms by Karthik Kambatla · 13 years ago
  43. 62d5b50 Fixed bug in dynamic app loading but there seems to be a conflict with dynamic dispatching. by Leo Neumeyer · 13 years ago
  44. 9fec63d Removed redundant dependency. by Leo Neumeyer · 13 years ago
  45. 9ba3013 Initial commit for ZK integration with S4 by Kishore Gopalakrishna · 13 years ago
  46. e049d65 Initial ZK integration with s4. by Kishore Gopalakrishna · 13 years ago
  47. 076e1bf Merge branch 'master' of https://github.com/leoneu/s4-piper by Kishore Gopalakrishna · 13 years ago
  48. f6f1247 Merge branch 's4-zk' by Kishore Gopalakrishna · 13 years ago
  49. 17a2547 Changed location of test tmp dir. by Leo Neumeyer · 13 years ago
  50. 5dde488 Merge pull request #6 from matthieumorel/s4-12 by Leo Neumeyer · 13 years ago
  51. e694064 removed trigger on WordCounterPE since triggers are tested elsewhere by Matthieu Morel · 13 years ago
  52. a1a546e Initial commit of s4-zk integration by Kishore Gopalakrishna · 13 years ago
  53. c87fa07 S4-12 : evaluate trigger condition by Matthieu Morel · 13 years ago
  54. 8a3d973 Adding code for S4 integration with ZK by Kishore Gopalakrishna · 13 years ago
  55. da4cdd7 I changed test io.s4.wordcount.WordCounterPE to use an onTrigger() method to make sure the test case fails until the eventTrigger matching code is fixed in App. by Leo Neumeyer · 13 years ago
  56. 9890d78 - NettyEmitter lazily connects on first send() call. by Karthik Kambatla · 13 years ago
  57. 79fd227 simple test for s4-comm protocols by Karthik Kambatla · 13 years ago
  58. ca61df4 cleanup by Leo Neumeyer · 13 years ago
  59. c8ab219 Changed package names from io.s4 to org.apache :-( :-) by Leo Neumeyer · 13 years ago
  60. 4282c5a Trying to get Server to load the counter app packaged as an s4r file. by Leo Neumeyer · 13 years ago
  61. a6e0ca6 Updated gitignore by Leo Neumeyer · 13 years ago
  62. d758d77 Clean up and documentation. by Leo Neumeyer · 13 years ago
  63. f044b18 Experimenting with class loaders. by Leo Neumeyer · 13 years ago
  64. 86c4d1e Merged dynamic dispatching code. by Leo Neumeyer · 13 years ago
  65. aa2d557 enhanced test for dynamic overload dispatcher by Matthieu Morel · 13 years ago
  66. 65da850 adaptations to new APIs by Matthieu Morel · 13 years ago
  67. 5e44c1d configured classpath by Matthieu Morel · 13 years ago
  68. 8fe83bd added simple wordcount regression test by Matthieu Morel · 13 years ago
  69. f66ea64 added dynamic event dispatch in PEs based on runtime type of events by Matthieu Morel · 13 years ago
  70. 0c401d6 Testing how to use MultiClassLoader to load apps dynamically. by Leo Neumeyer · 13 years ago
  71. eb99ac8 When events are sent to a local partition, they are no longer serialized and sent using the emmiter, instead the stream puts the event in the queue directly bypassing the comm layer. by Leo Neumeyer · 13 years ago
  72. 63e857b Replaced MapMaker with CacheBuilder in ProcessingElement. by Leo Neumeyer · 13 years ago
  73. bf0e201 Upgraded Guava lib to version 10.0.1. Clone triggers collection from proto to new PE instance. by Leo Neumeyer · 13 years ago
  74. 5f6243a Support for multiple triggers in PrcoessingElement. Once we merge with the dynamic dispatching code, we can use different triggers for each event type. Changed public method names to match new design. by Leo Neumeyer · 13 years ago
  75. 27eeb3e Fixed Model example. It expectes an exact event sequence so it wont work until we have Netty with blocking queues or support for bypassing the commlayer in local mode. by Leo Neumeyer · 13 years ago
  76. fc54a5e Replaced ReceiverListener interface with Stream for clarity and to simplify. Implemented matching of received event to target stream in Receiver using a lookup instead of looping in the Stream. More efficient, not affetced by number of streams. by Leo Neumeyer · 13 years ago
  77. 6a924e8 Added prefix s4- to all subprojects. by Leo Neumeyer · 13 years ago
  78. e3214d0 Created the Streamable interface and teh EventSource class for interapp communication. by Leo Neumeyer · 13 years ago
  79. 257e2eb Removed unused file. by Leo Neumeyer · 13 years ago
  80. bc07af4 Converted to multi-module project. by Leo Neumeyer · 13 years ago
  81. 4d2d5ab Tested loading counter app using Modules by Leo Neumeyer · 13 years ago
  82. b0ae9d6 Added appId to App and Event. Stream now sets both a unique streamId and the appId to identify target streams in the cluster. by Leo Neumeyer · 13 years ago
  83. 68a24d9 Load HelloApp class using JBOSS Modules. by Leo Neumeyer · 13 years ago
  84. a8c8600 Commented out assisted inject in gradle. by Leo Neumeyer · 13 years ago
  85. 41a7ab8 Added createStream() and createPE() methods in App. Removed StreamFactory class. by Leo Neumeyer · 13 years ago
  86. f491cc9 Put StreamFactory injection in App to remove Guice dependency from user classes. by Leo Neumeyer · 13 years ago
  87. f113adb Added documentation to comm layer. by Leo Neumeyer · 13 years ago
  88. ce35977 simplified cluster config by Leo Neumeyer · 13 years ago
  89. 749b03d simplifying cluster config by Leo Neumeyer · 13 years ago
  90. b8350f8 Moved defaultHasher to Module. by Leo Neumeyer · 13 years ago
  91. 5f4a34d Minor bug fixes. by Leo Neumeyer · 13 years ago
  92. 69b0728 Fixed tests. by Leo Neumeyer · 13 years ago
  93. a642c2e Some refactoring. by Leo Neumeyer · 13 years ago
  94. d511217 Added a stream factory class to hide details from API. by Leo Neumeyer · 13 years ago
  95. 5d788ad Merged comm layer. by Leo Neumeyer · 13 years ago
  96. d485ade Update counter example. by Leo Neumeyer · 13 years ago
  97. ce777a6 Use Guava MapMaker to manage PE instances with expiration. Add unit test for PEs with expiration. by Leo Neumeyer · 13 years ago
  98. b758b07 Broadcast; stream ids in events (rather than stream names) by Bruce Robbins · 13 years ago
  99. 7d300c2 Minor refactioring by Leo Neumeyer · 13 years ago
  100. 8c4cf8f Fixed bug in WindowedPE by Leo Neumeyer · 13 years ago