calrissian/flowmix issues and pull requests

#54 - flowmix design doc

Issue - State: open - Opened by zqhxuyuan over 8 years ago - 1 comment

#53 - Upgrade Apache Commons Collections to v3.2.2

Pull Request - State: closed - Opened by gmlewis over 8 years ago - 1 comment

#52 - Event tuple same key,but error size

Issue - State: open - Opened by zqhxuyuan about 9 years ago - 1 comment

#51 - JoinBolt didn't deal with buffer==null

Issue - State: open - Opened by zqhxuyuan about 9 years ago

#50 - Provide typed Aggregator abstraction to make it easier to write aggregators that deal with single types (numerical functions, etc..).

Issue - State: closed - Opened by cjnolet almost 10 years ago

#49 - Direct support for new Event's Type field

Issue - State: open - Opened by cjnolet almost 10 years ago

#48 - Off-heap storage of cached windows.

Issue - State: open - Opened by cjnolet almost 10 years ago

#47 - More abstract AbstractAggregator, *Aggregator are now using Abstract, tests and some ideas + bugfix

Pull Request - State: closed - Opened by miguelantonio almost 10 years ago - 15 comments

#46 - More abstract AbstractAggregator, *Aggregator are now using Abstract, tests and some ideas

Pull Request - State: closed - Opened by miguelantonio almost 10 years ago

#45 - Light Aggregator (not keeping the whole field group)

Issue - State: closed - Opened by miguelantonio almost 10 years ago - 2 comments

#44 - Unit tests for all aggregators

Issue - State: open - Opened by cjnolet almost 10 years ago

#43 - Rename Tuple to Attribute

Issue - State: open - Opened by cjnolet almost 10 years ago

#42 - Flowmix API on top of Apache Spark

Issue - State: open - Opened by cjnolet almost 10 years ago

#41 - Abstract aggregator for simple aggregation development

Pull Request - State: closed - Opened by miguelantonio almost 10 years ago - 2 comments

#40 - Release Flowmix 0.2.0

Issue - State: open - Opened by cjnolet about 10 years ago

#39 - The Event loader component should use the same parallelism as the rest of the topology

Issue - State: closed - Opened by cjnolet about 10 years ago

#38 - 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.

Issue - State: open - Opened by cjnolet about 10 years ago - 3 comments
Labels: enhancement

#37 - The TickSpout is only emitting ticks in nextTuple() which means it's very likely the ticks could get out of sync.

Issue - State: open - Opened by cjnolet about 10 years ago
Labels: bug

#36 - Stream SQL dialect to provide a higher level API around the builder DSL.

Issue - State: open - Opened by cjnolet about 10 years ago
Labels: enhancement

#35 - Join operator should perform all possible joins

Issue - State: open - Opened by cjnolet about 10 years ago
Labels: enhancement

#34 - Join operator should take a predicate to determine a successful join

Issue - State: open - Opened by cjnolet about 10 years ago
Labels: enhancement

#33 - Investigate possibility of placing API on top of Samza

Issue - State: open - Opened by cjnolet about 10 years ago

#32 - Solidify API and decouple from Core

Issue - State: open - Opened by cjnolet over 10 years ago

#31 - Implementations of all FlowOps need to provide equals() and hashCode() methods

Issue - State: open - Opened by cjnolet over 10 years ago
Labels: enhancement

#30 - AggregatedEvent's constructor taking in the event's previous stream as an argument, is never used.

Issue - State: open - Opened by cjnolet over 10 years ago
Labels: bug

#29 - MockEventGeneratorSpout should allow a list of events to be set in the constructor so that they can be more tuned to a use-case

Issue - State: closed - Opened by cjnolet over 10 years ago

#28 - To optimize resource usage, FlowmixFactory should allow the user to turn on which functions they want

Issue - State: open - Opened by cjnolet over 10 years ago
Labels: enhancement

#27 - Hash function used to create partitions should use Guava's hash builders.

Issue - State: open - Opened by cjnolet over 10 years ago - 1 comment

#26 - Support punctuation-style control signals

Issue - State: open - Opened by cjnolet over 10 years ago

#25 - Allow events to be broadcast to components which are listening.

Issue - State: open - Opened by cjnolet over 10 years ago

#24 - FlomwmixFactory should have a method to take a bolt for loading events

Issue - State: closed - Opened by cjnolet over 10 years ago

#23 - Common functionality in bolts needs to be placed in helper classes

Issue - State: open - Opened by cjnolet over 10 years ago

#22 - Aggregator window's window eviction fires unexpectedly because the window is only ever written to the cache once.

Issue - State: closed - Opened by cjnolet over 10 years ago
Labels: bug

#21 - LongSumAggregator's internal fields should be protected so that subclasses can access them

Issue - State: closed - Opened by cjnolet over 10 years ago

#20 - FilterOp should take a Filter class and not just assume a QueryBuilder

Issue - State: closed - Opened by cjnolet over 10 years ago

#19 - SplitterOp to allow a stream to go to multiple different streams

Issue - State: closed - Opened by cjnolet over 10 years ago - 1 comment

#18 - MockFlowLoaderSpout never adjusts loaded to true

Issue - State: closed - Opened by cjnolet over 10 years ago
Labels: bug

#17 - Allow time-based triggered windows to be synchronized

Issue - State: open - Opened by cjnolet over 10 years ago

#16 - Aggregator to support "rates" of counts/sums

Issue - State: open - Opened by cjnolet over 10 years ago

#15 - Support for filtering by visibilities

Issue - State: closed - Opened by cjnolet over 10 years ago - 1 comment

#14 - Spout to parse flows dynamically (i.e. passed in through webapp or JMS queue and serialized, etc..)

Issue - State: open - Opened by cjnolet over 10 years ago

#13 - Lexiencoders

Pull Request - State: closed - Opened by eawagner over 10 years ago

#12 - Simple aggregators

Issue - State: open - Opened by cjnolet over 10 years ago

#11 - Select and Sort operators should take varargs instead of .field() and .sortBy().

Issue - State: closed - Opened by cjnolet over 10 years ago

#10 - Sort operator

Issue - State: closed - Opened by cjnolet over 10 years ago

#9 - Custom expire for the guava cache backing the windows

Issue - State: open - Opened by cjnolet over 10 years ago

#8 - Flow object needs a kryo serializer.

Issue - State: open - Opened by cjnolet over 10 years ago

#7 - [StopGate] not closing the gate.

Issue - State: closed - Opened by cjnolet over 10 years ago
Labels: bug

#6 - Ability to orchestrate a window based on "control events"

Issue - State: closed - Opened by cjnolet over 10 years ago - 2 comments

#5 - Move criteria to mango

Issue - State: closed - Opened by cjnolet over 10 years ago

#4 - Stream outputs need to be managed internally so that streams can be "exported" to other streams

Issue - State: closed - Opened by cjnolet over 10 years ago

#3 - Exception stream for debugging/troubleshooting

Issue - State: open - Opened by cjnolet over 10 years ago

#2 - Binary streams demonstration

Issue - State: open - Opened by cjnolet over 10 years ago - 2 comments

#1 - Join Streams

Issue - State: closed - Opened by cjnolet over 10 years ago

GitHub / calrissian/flowmix issues and pull requests