calrissian flowmix issues

calrissian / flowmix

Flowmix is a flexible event processing engine for Apache Storm. It supports complex correlations of events via sliding/tumbling windows. It allows parallel streams to be processed that can be grouped together in different ways.

Apache License 2.0

55 stars 20 forks source link

issues

Newest

Newest Most commented Recently updated Oldest Least commented Least recently updated

flowmix design doc

#54 zqhxuyuan opened 8 years ago
1
Upgrade Apache Commons Collections to v3.2.2

#53 gmlewis closed 8 years ago
1
Event tuple same key,but error size

#52 zqhxuyuan opened 9 years ago
1
JoinBolt didn't deal with buffer==null

#51 zqhxuyuan opened 9 years ago
0
Provide typed Aggregator abstraction to make it easier to write aggregators that deal with single types (numerical functions, etc..).

#50 cjnolet closed 9 years ago
0
Direct support for new Event's Type field

#49 cjnolet opened 9 years ago
0
Off-heap storage of cached windows.

#48 cjnolet opened 9 years ago
0
More abstract AbstractAggregator, *Aggregator are now using Abstract, tests and some ideas + bugfix

#47 miguelantonio closed 9 years ago
15
More abstract AbstractAggregator, *Aggregator are now using Abstract, tests and some ideas

#46 miguelantonio closed 9 years ago
0
Light Aggregator (not keeping the whole field group)

#45 miguelantonio closed 9 years ago
2
Unit tests for all aggregators

#44 cjnolet opened 9 years ago
0
Rename Tuple to Attribute

#43 cjnolet opened 9 years ago
0
Flowmix API on top of Apache Spark

#42 cjnolet opened 9 years ago
0
Abstract aggregator for simple aggregation development

#41 miguelantonio closed 9 years ago
2
Release Flowmix 0.2.0

#40 cjnolet opened 10 years ago
0
The Event loader component should use the same parallelism as the rest of the topology

#39 cjnolet closed 10 years ago
0
We need a stress testing suite to show the true capability of Flowmix as well as to surface any bottlenecks that could seriously hinder the ability to process flows in real time.

#38 cjnolet opened 10 years ago
3
The TickSpout is only emitting ticks in nextTuple() which means it's very likely the ticks could get out of sync.

#37 cjnolet opened 10 years ago
0
Stream SQL dialect to provide a higher level API around the builder DSL.

#36 cjnolet opened 10 years ago
0
Join operator should perform all possible joins

#35 cjnolet opened 10 years ago
0
Join operator should take a predicate to determine a successful join

#34 cjnolet opened 10 years ago
0
Investigate possibility of placing API on top of Samza

#33 cjnolet opened 10 years ago
0
Solidify API and decouple from Core

#32 cjnolet opened 10 years ago
0
Implementations of all FlowOps need to provide equals() and hashCode() methods

#31 cjnolet opened 10 years ago
0
AggregatedEvent's constructor taking in the event's previous stream as an argument, is never used.

#30 cjnolet opened 10 years ago
0
MockEventGeneratorSpout should allow a list of events to be set in the constructor so that they can be more tuned to a use-case

#29 cjnolet closed 10 years ago
0
To optimize resource usage, FlowmixFactory should allow the user to turn on which functions they want

#28 cjnolet opened 10 years ago
0
Hash function used to create partitions should use Guava's hash builders.

#27 cjnolet opened 10 years ago
1
Support punctuation-style control signals

#26 cjnolet opened 10 years ago
0
Allow events to be broadcast to components which are listening.

#25 cjnolet opened 10 years ago
0
FlomwmixFactory should have a method to take a bolt for loading events

#24 cjnolet closed 10 years ago
0
Common functionality in bolts needs to be placed in helper classes

#23 cjnolet opened 10 years ago
0
Aggregator window's window eviction fires unexpectedly because the window is only ever written to the cache once.

#22 cjnolet closed 10 years ago
0
LongSumAggregator's internal fields should be protected so that subclasses can access them

#21 cjnolet closed 10 years ago
0
FilterOp should take a Filter class and not just assume a QueryBuilder

#20 cjnolet closed 10 years ago
0
SplitterOp to allow a stream to go to multiple different streams

#19 cjnolet closed 10 years ago
1
MockFlowLoaderSpout never adjusts loaded to true

#18 cjnolet closed 10 years ago
0
Allow time-based triggered windows to be synchronized

#17 cjnolet opened 10 years ago
0
Aggregator to support "rates" of counts/sums

#16 cjnolet opened 10 years ago
0
Support for filtering by visibilities

#15 cjnolet closed 10 years ago
1
Spout to parse flows dynamically (i.e. passed in through webapp or JMS queue and serialized, etc..)

#14 cjnolet opened 10 years ago
0
Lexiencoders

#13 eawagner closed 10 years ago
0
Simple aggregators

#12 cjnolet opened 10 years ago
0
Select and Sort operators should take varargs instead of .field() and .sortBy().

#11 cjnolet closed 10 years ago
0
Sort operator

#10 cjnolet closed 10 years ago
0
Custom expire for the guava cache backing the windows

#9 cjnolet opened 10 years ago
0
Flow object needs a kryo serializer.

#8 cjnolet opened 10 years ago
0
[StopGate] not closing the gate.

#7 cjnolet closed 10 years ago
0
Ability to orchestrate a window based on "control events"

#6 cjnolet closed 10 years ago
2
Move criteria to mango

#5 cjnolet closed 10 years ago
0