Ecosyste.ms: Issues

An open API service for providing issue and pull request metadata for open source projects.

GitHub / sorenmacbeth/flambo issues and pull requests

#100 - Update json-file and json-rdd to Spark 2.0

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

#100 - Update json-file and json-rdd to Spark 2.0

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

#99 - Update read-csv to Spark 2.0

Pull Request - State: closed - Opened by zero323 over 8 years ago - 3 comments

#99 - Update read-csv to Spark 2.0

Pull Request - State: closed - Opened by zero323 over 8 years ago - 3 comments

#98 - Cannot use map on RDD action result

Issue - State: closed - Opened by minor6th over 8 years ago - 8 comments

#98 - Cannot use map on RDD action result

Issue - State: closed - Opened by minor6th over 8 years ago - 8 comments

#97 - 0.8.0-SNAPSHOT failed with java.lang.ClassCastException: clojure.lang.LazySeq

Issue - State: closed - Opened by ogis-hashi over 8 years ago - 2 comments

#97 - 0.8.0-SNAPSHOT failed with java.lang.ClassCastException: clojure.lang.LazySeq

Issue - State: closed - Opened by ogis-hashi over 8 years ago - 2 comments

#95 - spark 2.0 text-file error

Issue - State: closed - Opened by clojurians-org over 8 years ago - 5 comments

#95 - spark 2.0 text-file error

Issue - State: closed - Opened by clojurians-org over 8 years ago - 5 comments

#94 - How to define custom keys and Partitioners?

Issue - State: closed - Opened by punit-naik over 8 years ago - 1 comment

#94 - How to define custom keys and Partitioners?

Issue - State: closed - Opened by punit-naik over 8 years ago - 1 comment

#93 - Add save-as-text-file with the extra compression codec parameter

Pull Request - State: closed - Opened by rborer over 8 years ago - 2 comments

#93 - Add save-as-text-file with the extra compression codec parameter

Pull Request - State: closed - Opened by rborer over 8 years ago - 2 comments

#92 - Implemented future-facts in tests

Pull Request - State: closed - Opened by joshrotenberg almost 9 years ago - 1 comment

#92 - Implemented future-facts in tests

Pull Request - State: closed - Opened by joshrotenberg almost 9 years ago - 1 comment

#91 - Topic map in flambo.streaming/kafka-stream

Issue - State: closed - Opened by punit-naik almost 9 years ago - 2 comments

#91 - Topic map in flambo.streaming/kafka-stream

Issue - State: closed - Opened by punit-naik almost 9 years ago - 2 comments

#90 - Correct defregistrator example in README.md

Pull Request - State: closed - Opened by aromatt almost 9 years ago - 1 comment

#90 - Correct defregistrator example in README.md

Pull Request - State: closed - Opened by aromatt almost 9 years ago - 1 comment

#89 - Update spark-csv version 1.0.1 -> 1.4.0

Pull Request - State: closed - Opened by zero323 almost 9 years ago - 2 comments

#88 - Update Spark version 1.6.0 -> 1.6.1

Pull Request - State: closed - Opened by zero323 almost 9 years ago - 1 comment

#88 - Update Spark version 1.6.0 -> 1.6.1

Pull Request - State: closed - Opened by zero323 almost 9 years ago - 1 comment

#87 - [WIP] Spark SQL API

Pull Request - State: closed - Opened by zero323 almost 9 years ago - 7 comments

#87 - [WIP] Spark SQL API

Pull Request - State: closed - Opened by zero323 almost 9 years ago - 7 comments

#86 - Attempting to call unbound fn: #'flambo.function/pair-flat-map-function

Issue - State: closed - Opened by viebel almost 9 years ago - 2 comments

#86 - Attempting to call unbound fn: #'flambo.function/pair-flat-map-function

Issue - State: closed - Opened by viebel almost 9 years ago - 2 comments

#85 - f/map doesn't work on a sql DataFrame

Issue - State: closed - Opened by RasterBurn about 9 years ago - 2 comments

#85 - f/map doesn't work on a sql DataFrame

Issue - State: closed - Opened by RasterBurn about 9 years ago - 2 comments

#84 - How to destructure dataframe/rdd?

Issue - State: closed - Opened by sihingkk over 9 years ago - 1 comment

#83 - AOT compile

Pull Request - State: closed - Opened by kurtharriger over 9 years ago - 2 comments

#83 - AOT compile

Pull Request - State: closed - Opened by kurtharriger over 9 years ago - 2 comments

#82 - Exception: Unable to resolve symbol: `model` in this context

Issue - State: closed - Opened by BrunoBonacci over 9 years ago - 3 comments

#81 - Update for documentation after flailing about like a Clojure noob and…

Pull Request - State: closed - Opened by lastcoolnameleft over 9 years ago - 1 comment

#80 - defsparkfn does not support docstrings

Issue - State: closed - Opened by b-ryan over 9 years ago - 1 comment

#80 - defsparkfn does not support docstrings

Issue - State: closed - Opened by b-ryan over 9 years ago - 1 comment

#79 - Adds `whole-text-files` function and enables min-partitions for `text-file`

Pull Request - State: closed - Opened by anujsrc over 9 years ago - 2 comments

#79 - Adds `whole-text-files` function and enables min-partitions for `text-file`

Pull Request - State: closed - Opened by anujsrc over 9 years ago - 2 comments

#78 - Flambo Stand-Alone Applications Broken

Issue - State: closed - Opened by snunez1 over 9 years ago - 14 comments

#77 - Adding take-ordered with default comparator

Pull Request - State: closed - Opened by ararog over 9 years ago - 1 comment

#76 - Fix misplaced docstring

Pull Request - State: closed - Opened by arrdem over 9 years ago

#75 - Adding take-ordered with default comparator

Pull Request - State: closed - Opened by ararog over 9 years ago - 1 comment

#74 - Running on mesos with lein run

Issue - State: closed - Opened by krukowski over 9 years ago - 2 comments

#72 - How to create a comparator from api/fn macro?

Issue - State: closed - Opened by ararog over 9 years ago - 2 comments

#71 - Adding support to min, max and takeOrdered

Pull Request - State: closed - Opened by ararog over 9 years ago - 1 comment

#70 - Flambo on Mesos

Issue - State: closed - Opened by hellonico over 9 years ago - 1 comment

#69 - Adding back in the multi-arity function of `union`.

Pull Request - State: closed - Opened by whoahbot over 9 years ago

#68 - 0.6.0 not available yet on clojars

Issue - State: closed - Opened by esumitra over 9 years ago - 1 comment

#67 - Add support for RDD/min and max

Issue - State: closed - Opened by ararog over 9 years ago - 1 comment

#66 - Using sparksql rows in flambo

Issue - State: closed - Opened by ararog over 9 years ago - 4 comments

#65 - Can't map in saveAsTextFile

Issue - State: closed - Opened by afandian over 9 years ago - 1 comment

#64 - Tutorial profile.clj fix.

Pull Request - State: closed - Opened by alexrobbins over 9 years ago - 1 comment

#63 - Add basic Spark SQL tests and more support for SQLContext methods.

Pull Request - State: closed - Opened by chetmancini almost 10 years ago - 6 comments

#62 - Remove unused imports and add imports for fully qualified Java classes

Pull Request - State: closed - Opened by chetmancini almost 10 years ago - 1 comment

#61 - JavaDoubleRDD Strangeness

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

#60 - Improved SQL Functions and Tests

Pull Request - State: closed - Opened by snunez1 almost 10 years ago - 1 comment

#59 - MLlib API

Issue - State: closed - Opened by snunez1 almost 10 years ago - 13 comments

#58 - SQL: Tests and Functionality

Pull Request - State: closed - Opened by snunez1 almost 10 years ago - 1 comment

#57 - Tests for `flambo.sql`

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

#56 - Dataframes lacks CSV Reader

Issue - State: closed - Opened by snunez1 almost 10 years ago - 1 comment

#55 - Sn branch

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

#54 - Master: Update for flambo 0.6.0

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

#53 - No matching method found for join

Issue - State: closed - Opened by snunez1 almost 10 years ago - 3 comments

#52 - ClassNotFoundException: flambo.function.Function

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

#51 - JARs not in Clojars or Central

Issue - State: closed - Opened by snunez1 almost 10 years ago - 1 comment

#50 - Getting ready for 0.5.0.

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

#49 - Serialize functions with kryo

Pull Request - State: closed - Opened by kul almost 10 years ago - 7 comments

#48 - Basic Spark 1.3 Compatibility

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

#47 - No matching method found: reduceByKey

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

#46 - [Query] Buffer Underflow in Kryo

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

#45 - Updates to the README for 0.5.0.

Pull Request - State: closed - Opened by whoahbot almost 10 years ago - 1 comment

#44 - Closes #43

Pull Request - State: closed - Opened by kul about 10 years ago - 3 comments

#43 - Upgrade to spark 1.2.0

Issue - State: closed - Opened by kul about 10 years ago - 1 comment

#42 - Exception: namespace 'flambo.function' not found

Issue - State: closed - Opened by alilee about 10 years ago - 18 comments

#41 - java.lang.SecurityException when upgrading to 1.1.1

Issue - State: closed - Opened by danoyoung about 10 years ago - 10 comments

#40 - Help to adding missing APIs

Issue - State: closed - Opened by alilee about 10 years ago - 5 comments

#39 - Update examples

Issue - State: closed - Opened by tcfuji about 10 years ago - 6 comments

#38 - Tests for `flambo.streaming`

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

#37 - Add examples and README info on `flambo.streaming`

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

#36 - Add support for flume

Pull Request - State: closed - Opened by dougselph about 10 years ago - 1 comment

#35 - Add JavaRDDLike.cartesian

Pull Request - State: closed - Opened by rzeigler about 10 years ago - 1 comment

#34 - Add union function to API.

Pull Request - State: closed - Opened by mthomure about 10 years ago

#33 - fix histogram bug, add tests

Pull Request - State: closed - Opened by mthomure about 10 years ago

#32 - Add 'histogram' to API.

Pull Request - State: closed - Opened by mthomure about 10 years ago

#31 - Check the type of dstream before doing reduceByKey

Pull Request - State: closed - Opened by jogjayr about 10 years ago - 3 comments

#30 - Issue #23 and other additions

Pull Request - State: closed - Opened by jogjayr about 10 years ago - 1 comment

#29 - Balance parens in Tutorial code snippets

Pull Request - State: closed - Opened by johnchapin over 10 years ago - 1 comment

#28 - Flambo/develop

Pull Request - State: closed - Opened by chrisbetz over 10 years ago - 4 comments

#27 - Another take on serialization of functions

Pull Request - State: closed - Opened by dajac over 10 years ago - 12 comments

#26 - Changes .map to .mapToPair when using the reduceByKey functionality

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

#25 - Few changes for Spark Streaming

Pull Request - State: closed - Opened by viksit over 10 years ago - 3 comments

#24 - Streaming reduce by key doesn't work

Issue - State: closed - Opened by viksit over 10 years ago - 6 comments

#23 - Cannot cast flambo.function.Function2 to scala.Function2 (Streaming)

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

#22 - Add `map-partition`, `map-partition-with-index` and `foreach-partition`.

Pull Request - State: closed - Opened by kul over 10 years ago - 1 comment

#21 - Using Flambo as a checkout dependency

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

#20 - Accessing yarn-site.xml

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

#19 - cache question

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