You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by ka...@apache.org on 2017/02/07 01:28:24 UTC
[11/12] storm git commit: Merge branch 'streams' of
https://github.com/arunmahadevan/storm into STORM-1961-merge
Merge branch 'streams' of https://github.com/arunmahadevan/storm into STORM-1961-merge
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/00b0fd75
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/00b0fd75
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/00b0fd75
Branch: refs/heads/master
Commit: 00b0fd75025b87c96fd535387964f16be42cb776
Parents: a7cdfef 37ee12c
Author: Jungtaek Lim <ka...@gmail.com>
Authored: Tue Feb 7 10:23:16 2017 +0900
Committer: Jungtaek Lim <ka...@gmail.com>
Committed: Tue Feb 7 10:23:16 2017 +0900
----------------------------------------------------------------------
.../storm/starter/streams/AggregateExample.java | 95 +++
.../storm/starter/streams/BranchExample.java | 71 +++
.../streams/GroupByKeyAndWindowExample.java | 114 ++++
.../storm/starter/streams/JoinExample.java | 109 ++++
.../starter/streams/StateQueryExample.java | 116 ++++
.../starter/streams/StatefulWordCount.java | 88 +++
.../starter/streams/TypedTupleExample.java | 63 ++
.../starter/streams/WindowedWordCount.java | 79 +++
.../storm/starter/streams/WordCountToBolt.java | 105 ++++
.../storm/annotation/InterfaceStability.java | 54 ++
.../src/jvm/org/apache/storm/streams/Edge.java | 41 ++
.../org/apache/storm/streams/GroupingInfo.java | 100 +++
.../src/jvm/org/apache/storm/streams/Node.java | 170 ++++++
.../src/jvm/org/apache/storm/streams/Pair.java | 103 ++++
.../org/apache/storm/streams/PairStream.java | 525 ++++++++++++++++
.../org/apache/storm/streams/PartitionNode.java | 37 ++
.../org/apache/storm/streams/ProcessorBolt.java | 70 +++
.../storm/streams/ProcessorBoltDelegate.java | 348 +++++++++++
.../org/apache/storm/streams/ProcessorNode.java | 83 +++
.../apache/storm/streams/RefCountedTuple.java | 64 ++
.../jvm/org/apache/storm/streams/SinkNode.java | 44 ++
.../jvm/org/apache/storm/streams/SpoutNode.java | 48 ++
.../storm/streams/StatefulProcessorBolt.java | 116 ++++
.../jvm/org/apache/storm/streams/Stream.java | 515 ++++++++++++++++
.../org/apache/storm/streams/StreamBolt.java | 38 ++
.../org/apache/storm/streams/StreamBuilder.java | 602 +++++++++++++++++++
.../org/apache/storm/streams/StreamState.java | 43 ++
.../org/apache/storm/streams/StreamUtil.java | 69 +++
.../storm/streams/StreamsEdgeFactory.java | 29 +
.../org/apache/storm/streams/UniqueIdGen.java | 56 ++
.../org/apache/storm/streams/WindowNode.java | 39 ++
.../storm/streams/WindowedProcessorBolt.java | 137 +++++
.../storm/streams/operations/BiFunction.java | 37 ++
.../streams/operations/CombinerAggregator.java | 97 +++
.../storm/streams/operations/Consumer.java | 32 +
.../streams/operations/FlatMapFunction.java | 27 +
.../storm/streams/operations/Function.java | 34 ++
.../streams/operations/IdentityFunction.java | 31 +
.../storm/streams/operations/Operation.java | 26 +
.../streams/operations/PairFlatMapFunction.java | 30 +
.../storm/streams/operations/PairFunction.java | 30 +
.../streams/operations/PairValueJoiner.java | 40 ++
.../storm/streams/operations/Predicate.java | 33 +
.../storm/streams/operations/PrintConsumer.java | 30 +
.../storm/streams/operations/Reducer.java | 35 ++
.../storm/streams/operations/StateUpdater.java | 67 +++
.../storm/streams/operations/ValueJoiner.java | 36 ++
.../streams/operations/aggregators/Count.java | 47 ++
.../streams/operations/aggregators/LongSum.java | 45 ++
.../operations/mappers/PairValueMapper.java | 51 ++
.../operations/mappers/TupleValueMapper.java | 30 +
.../operations/mappers/TupleValueMappers.java | 174 ++++++
.../streams/operations/mappers/ValueMapper.java | 45 ++
.../operations/mappers/ValuesMapper.java | 48 ++
.../processors/AggregateByKeyProcessor.java | 78 +++
.../streams/processors/AggregateProcessor.java | 69 +++
.../storm/streams/processors/BaseProcessor.java | 109 ++++
.../streams/processors/BatchProcessor.java | 25 +
.../streams/processors/BranchProcessor.java | 41 ++
.../processors/ChainedProcessorContext.java | 66 ++
.../processors/EmittingProcessorContext.java | 155 +++++
.../streams/processors/FilterProcessor.java | 35 ++
.../streams/processors/FlatMapProcessor.java | 35 ++
.../processors/FlatMapValuesProcessor.java | 36 ++
.../streams/processors/ForEachProcessor.java | 33 +
.../processors/ForwardingProcessorContext.java | 102 ++++
.../storm/streams/processors/JoinProcessor.java | 152 +++++
.../storm/streams/processors/MapProcessor.java | 33 +
.../streams/processors/MapValuesProcessor.java | 34 ++
.../MergeAggregateByKeyProcessor.java | 54 ++
.../processors/MergeAggregateProcessor.java | 47 ++
.../storm/streams/processors/PeekProcessor.java | 34 ++
.../storm/streams/processors/Processor.java | 54 ++
.../streams/processors/ProcessorContext.java | 62 ++
.../processors/ReduceByKeyProcessor.java | 52 ++
.../streams/processors/ReduceProcessor.java | 43 ++
.../streams/processors/StateQueryProcessor.java | 48 ++
.../streams/processors/StatefulProcessor.java | 36 ++
.../processors/UpdateStateByKeyProcessor.java | 49 ++
.../org/apache/storm/streams/tuple/Tuple10.java | 112 ++++
.../org/apache/storm/streams/tuple/Tuple3.java | 70 +++
.../org/apache/storm/streams/tuple/Tuple4.java | 76 +++
.../org/apache/storm/streams/tuple/Tuple5.java | 82 +++
.../org/apache/storm/streams/tuple/Tuple6.java | 89 +++
.../org/apache/storm/streams/tuple/Tuple7.java | 94 +++
.../org/apache/storm/streams/tuple/Tuple8.java | 100 +++
.../org/apache/storm/streams/tuple/Tuple9.java | 106 ++++
.../storm/streams/windowing/BaseWindow.java | 64 ++
.../storm/streams/windowing/SlidingWindows.java | 151 +++++
.../streams/windowing/TumblingWindows.java | 119 ++++
.../apache/storm/streams/windowing/Window.java | 70 +++
.../topology/StatefulWindowedBoltExecutor.java | 4 +-
.../storm/topology/WindowedBoltExecutor.java | 4 +-
.../storm/topology/base/BaseWindowedBolt.java | 37 +-
.../windowing/AbstractTridentWindowManager.java | 2 +-
.../storm/windowing/CountEvictionPolicy.java | 8 +-
.../apache/storm/windowing/EvictionPolicy.java | 7 +
.../storm/windowing/TimeEvictionPolicy.java | 17 +-
.../apache/storm/windowing/TupleWindowImpl.java | 11 +
.../windowing/WatermarkCountEvictionPolicy.java | 10 +-
.../windowing/WatermarkTimeEvictionPolicy.java | 4 +-
.../jvm/org/apache/storm/windowing/Window.java | 7 +
.../windowing/WindowLifecycleListener.java | 3 +-
.../apache/storm/windowing/WindowManager.java | 2 +-
.../apache/storm/streams/ProcessorBoltTest.java | 174 ++++++
.../streams/StatefulProcessorBoltTest.java | 111 ++++
.../apache/storm/streams/StreamBuilderTest.java | 268 +++++++++
.../streams/WindowedProcessorBoltTest.java | 110 ++++
.../streams/processors/JoinProcessorTest.java | 108 ++++
.../storm/windowing/WindowManagerTest.java | 2 +-
110 files changed, 8671 insertions(+), 29 deletions(-)
----------------------------------------------------------------------