Open Hub
Open Hub

 Settings |  Report Duplicate

1
I Use This!
Activity Not Available

Commits : Listings

Analyzed 12 months ago. based on code collected 12 months ago.
Jan 16, 2023 — Jan 16, 2024
Commit Message Contributor Files Modified Lines Added Lines Removed Code Location Date
added some images for the documentation and updated the PipelineTest to make sure that array passing works.
okram
More... over 14 years ago
added lots of useful pipes here. First Pipeline now takes a Array... in its constructor so its easier to create a Pipeline -- no needing to Arrays.asList() anymore. Added BufferPipe that is like aggregate, but doesn't create the aggregate in one big batch, but slowly grows it objects flow through it. Created HistoryPipe that, in concert with bufferpipe, will allow you to go back to a previous point in the pipeline. Now you can do the ../ construct from Gremlin using Pipes. Added test cases for all this and everything seems to work fine.
okram
More... over 14 years ago
went through the painful process of JavaDoc'ing most of the Pipes. This is useful as I don't plan to Wiki all the pipes and will simply refer to the JavaDoc as the primary documentation for this package.
okram
More... over 14 years ago
went through the painful process of JavaDoc'ing most of the Pipes. This is useful as I don't plan to Wiki all the pipes and will simply refer to the JavaDoc as the primary documentation for this package.
okram
More... over 14 years ago
simplified the split pipe package -- allows now for the dynamic addition of new splits. Created two new Pipes---ProductPipe and KeyCombinePipe. ProductPipe will take a pipe and an object and create a Pair (left or right joined) of the incoming pipe object and the provided object. KeyCombinePipe acts as a key combiner (like in MapReduce) and will join values by a key creating a Map<key,list<value>> type data structure.
okram
More... over 14 years ago
created SideEffectCapPipe--it allows you to cap any sideeffect and as such, make the sideeffect of a pipe its end. This is a much more general and scalable solution than to have a cap package which mimics all the sideeffect pipes. Started on the combiner package which provides combiners --- in the map/reduce sense. So far, there is one, count combine. Next is keycombine. Test cases written, stuff works. Lookin' good.
okram
More... over 14 years ago
created SideEffectCapPipe--it allows you to cap any sideeffect and as such, make the sideeffect of a pipe its end. This is a much more general and scalable solution than to have a cap package which mimics all the sideeffect pipes. Started on the combiner package which provides combiners --- in the map/reduce sense. So far, there is one, count combine. Next is keycombine. Test cases written, stuff works. Lookin' good.
okram
More... over 14 years ago
added the concept of pipe caps. These are pipes that process all their inputs and then simply return a single output -- like the butt end of a pipe. Added the first one called CountPipeCap. Added IdentityPipe which does nothing but return its input--this is good for creating test cases. Did some work updating Merge and Split base classes---this is the next big push to really demonstrate the power of pipes. A Pipe is now an Iteratator and an Iterable so you can while hasNext or foreach the results---added test cases to make sure everything behaves correctly. Also, a pipe now can take an Iteratble thus, you no longer have to Arrays.asList().iterator for the initial setStart.
okram
More... over 14 years ago
Pipes now implement Iterable<E>. Very simple--since they also implement Iterator<E> then the method iterator() just returns this.
okram
More... over 14 years ago
updated pipes logo...updated serial split pipes.
okram
More... over 14 years ago
updated README
okram
More... over 14 years ago
updated README.
okram
More... over 14 years ago
added duplicatefilterpipe. This pipe filters out objects that it has already seen pass through it. obviously, the large the more heterogenous objects and the more objects that flow through this pipe, the slower it gets. In short, it maintains an internal HashSet<S> so as that Set grows, it takes longer to search for a repeated object.
okram
More... over 14 years ago
cleaned up the pom and and added some more text to README.textile. Just setting the stage.
okram
More... over 14 years ago
minor issues with pom.xml---removed unneeded dependencies and had a spelling error causing the package to be named differently.
okram
More... over 14 years ago
migrated all of the pipe work out of blueprints and into its own projects --- pipes. There is still a disjoint between the serial and concurrent implementations. The next big step is to merge these into one framework.
okram
More... over 14 years ago
migrated all of the pipe work out of blueprints and into its own projects --- pipes. There is still a disjoint between the serial and concurrent implementations. The next big step is to merge these into one framework.
okram
More... over 14 years ago
migrated all of the pipe work out of blueprints and into its own projects --- pipes. There is still a disjoint between the serial and concurrent implementations. The next big step is to merge these into one framework.
okram
More... over 14 years ago
git issues with my username..testing.
okram
More... over 14 years ago
first commit---will migrate over all the pipe and pipex work over from blueprints next.
Marko Rodriguez
More... over 14 years ago