Code

Node multilang protocol implementation#2

Code

Open

anyatch wants to merge 46 commits intomasterforter/storm:masterfrom nodejs-internal-reviewedforter/storm:nodejs-internal-reviewedCopy head branch name to clipboard

Commits

Commits on Jun 26, 2014

• Change storm-core to compile

  anyatch

  committed
  e24ffb1

  Copy full SHA for e24ffb1

• Add BasicBolt js implementation (tested) and Spout implementation (not tested)

  anyatch

  committed
  04ce472

  Copy full SHA for 04ce472

• Change storm-core to compile

  anyatch

  committed
  e2b561f

  Copy full SHA for e2b561f

• Fix SplitSentenceBolt inheritance

  anyatch

  committed
  83e8040

  Copy full SHA for 83e8040

• Fix spout handleCommand

  anyatch

  committed
  902fa77

  Copy full SHA for 902fa77

Commits on Jun 29, 2014

• Fix Spout js implementation. WordCountTopology works with js bolt and spout.

  anyatch

  committed
  7c6e999

  Copy full SHA for 7c6e999

• Add js implemetation of storm - basic bolt and spout.

  anyatch

  committed
  f3f3e5c

  Copy full SHA for f3f3e5c

Commits on Jun 30, 2014

• Pass callback to BasicBolt.process to enable async functionality. Move general methods into Storm class

  anyatch

  committed
  2cfc908

  Copy full SHA for 2cfc908

• Add async bold

  anyatch

  committed
  e996e16

  Copy full SHA for e996e16

• Fix call to fail after process - pass tuple

  anyatch

  committed
  9eee5df

  Copy full SHA for 9eee5df

Commits on Jul 1, 2014

• Remove storm.js copy

  anyatch

  committed
  b644a1f

  Copy full SHA for b644a1f

• Fix inheritence mess. Fix randomsentence spout initialize

  anyatch

  committed
  6fcc42c

  Copy full SHA for 6fcc42c

• Add documentation to modules

  anyatch

  committed
  94ed360

  Copy full SHA for 94ed360

• Remove async run implementation

  anyatch

  committed
  847b509

  Copy full SHA for 847b509

• Change callback to done.

  anyatch

  committed
  e4d15d0

  Copy full SHA for e4d15d0

• Pass sentence list to the ocnstructor of the spout

  anyatch

  committed
  32dbb93

  Copy full SHA for 32dbb93

• Add documentation to random int method

  anyatch

  committed
  a2e2ab8

  Copy full SHA for a2e2ab8

• Use isFirstMessage instead of counting messages

  anyatch

  committed
  dc19eb7

  Copy full SHA for dc19eb7

Commits on Jul 2, 2014

• Pass the error on fail

  anyatch

  committed
  2d3a511

  Copy full SHA for 2d3a511

• Restore pom.xml to the original state

  anyatch

  committed
  920e383

  Copy full SHA for 920e383

• Restore original WordCountTopology.java. Add WordCountTopologyNode.java with node example

  anyatch

  committed
  fc920ca

  Copy full SHA for fc920ca

• Delete xml that wasn't here on original storm

  anyatch

  committed
  fe2d0d6

  Copy full SHA for fe2d0d6

• Changen parameter name - taskId to taskI(ds (because its a list). Add comments explaining task id callbacks functionality

  anyatch

  committed
  5603bee

  Copy full SHA for 5603bee

• Change taskId to taskIds

  anyatch

  committed
  f8522f8

  Copy full SHA for f8522f8

• In case no callback is passed when emitting, use a default callback

  anyatch

  committed
  47a426b

  Copy full SHA for 47a426b

• Remove dead code

  anyatch

  committed
  e71cc8c

  Copy full SHA for e71cc8c

• Change callback to done to match common format

  anyatch

  committed
  f573112

  Copy full SHA for f573112

• Change method name from callback to done

  anyatch

  committed
  ab1183b

  Copy full SHA for ab1183b

• Delete unnecessary and illegal log messages (before changing to storm logger)

  anyatch

  committed
  c446f91

  Copy full SHA for c446f91

• Delete logToFile and all references to it. Use storm logging system

  anyatch

  committed
  977a498

  Copy full SHA for 977a498

• Add documentation

  anyatch

  committed
  ea7269f

  Copy full SHA for ea7269f

Commits on Jul 3, 2014

• Add documentation, delete unnecessary require

  anyatch

  committed
  36764ba

  Copy full SHA for 36764ba

• Restore fs

  anyatch

  committed
  6b73c35

  Copy full SHA for 6b73c35

• Fix documentation

  anyatch

  committed
  add2e69

  Copy full SHA for add2e69

• Fix documentation

  anyatch

  committed
  d6a659e

  Copy full SHA for d6a659e

• Fix documentation

  anyatch

  committed
  20c2225

  Copy full SHA for 20c2225

• Extract create tuple id into a function

  anyatch

  committed
  4e3270c

  Copy full SHA for 4e3270c

• Change emit api - receive json instead of separate parsms

  anyatch

  committed
  2184834

  Copy full SHA for 2184834

• Docuemnt emit and emitDirect

  anyatch

  committed
  761b672

  Copy full SHA for 761b672

• Merge pull request #1 from forter/nodejs-initial

  Show description for 2b7ceaa
  itaifrenkel

  committed
  2b7ceaa

  Copy full SHA for 2b7ceaa

Commits on Jul 14, 2014

• Delete log messages from storm base classes. Delete unused method

  anyatch

  committed
  8e1824d

  Copy full SHA for 8e1824d

• Fix anchor tuple bug - dont save it in the bolts stats, pass the responsibility to the process method

  anyatch

  committed
  74b0e9f

  Copy full SHA for 74b0e9f

Commits on Jul 15, 2014

• Fix type.\nChange method name to camel case. Change quotes to format for json. Delete git add brain/storm.js\nDelete erroneous method override

  anyatch

  committed
  b54e0b6

  Copy full SHA for b54e0b6

• Fix type. Change method name to camel case. Change quotes to format for json. Delete git add brain/storm.js. Delete erroneous method override

  anyatch

  committed
  686ec2c

  Copy full SHA for 686ec2c

Commits on Jul 16, 2014

• Merge branch 'nodejs-internal-reviewed' of https://github.com/Ryzyco/incubator-storm into nodejs-internal-reviewed

  Show description for 4076545
  anyatch

  committed
  4076545

  Copy full SHA for 4076545

• Fix bug in storm spout/bolt initialization - first write a file names as the pid number and then send the pid to parent

  anyatch

  committed
  945495c

  Copy full SHA for 945495c