dwestheide/kontextfrei

Issues

• Add setName operator

  #59 opened 6 years ago by simonjscott
  2

• add support for emptyRDD method of SparkContext

  #62 opened 6 years ago by simonjscott
  3

• Add sortByKey operator

  #55 opened 6 years ago by dwestheide
  1

• Add filterByRange operator

  #57 opened 6 years ago by dwestheide
  1

• Add 'partitionBy' operator

  #64 opened 6 years ago by simonjscott
  5

• Spark UI shows call site as kontextfrei

  #66 opened 6 years ago by simonjscott
  3

• Add support for Spark 2.4.0

  #61 opened 6 years ago by dwestheide
  1

• Add repartitionAndSortWithinPartitions operator

  #56 opened 6 years ago by dwestheide
  1

• Can we suggest spark to move over to this pattern?

  #58 opened 6 years ago by mr-nano
  1

• Add treeAggregate action

  #47 opened 7 years ago by dwestheide
  0

• Add treeReduce action

  #44 opened 7 years ago by dwestheide
  0

• Add max and min actions

  #53 opened 7 years ago by dwestheide
  0

• Add zipWithUniqueId operator

  #49 opened 7 years ago by dwestheide
  0

• Add zipWithIndex operator

  #48 opened 7 years ago by dwestheide
  0

• Add the `aggregate` action

  #46 opened 7 years ago by dwestheide
  0

• Add fold action

  #45 opened 7 years ago by dwestheide
  0

• Add reduce action

  #43 opened 7 years ago by dwestheide
  0

• Add zipPartitions operators

  #38 opened 7 years ago by dwestheide
  0

• Add foreachPartition action

  #40 opened 7 years ago by dwestheide
  0

• Add the toLocalIterator action

  #41 opened 7 years ago by dwestheide
  0

• Add isEmpty action

  #54 opened 7 years ago by dwestheide
  0

• Add the `foreach` action

  #39 opened 7 years ago by dwestheide
  0

• Add glom operator

  #35 opened 7 years ago by dwestheide
  0

• Add persist and unpersist operators

  #31 opened 7 years ago by dwestheide
  0

• Add subtract operators

  #42 opened 7 years ago by dwestheide
  0

• Add `zip` operator

  #37 opened 7 years ago by dwestheide
  0

• Add the three `intersection` operators defined on `RDD`

  #34 opened 7 years ago by dwestheide
  0

• Add groupBy operator with Partitioner parameter

  #36 opened 7 years ago by dwestheide
  0

• Add `sortBy` operator with `numPartitions` parameter

  #33 opened 7 years ago by dwestheide
  0

• Add `distinct` operator with `numPartitions`

  #32 opened 7 years ago by dwestheide
  0

• Add top action

  #51 opened 7 years ago by dwestheide
  0

• Add takeOrdered action

  #52 opened 7 years ago by dwestheide
  0

• Add take action

  #50 opened 7 years ago by dwestheide
  0

• Add `coalesce` operator

  #1 opened 7 years ago by dwestheide
  0

• Add `repartition` operator

  #2 opened 7 years ago by dwestheide
  0

• Provide ScalaCheck Gen and Arbitrary instance

  #27 opened 8 years ago by dwestheide
  0

• Provide instances of ScalaTest `Collecting` typeclass in kontextfrei-scalatest

  #11 opened 8 years ago by dwestheide
  0

• Ensure function signatures use a consistent style

  #24 opened 8 years ago by dwestheide
  0

• Allow more flexible builds against multiple Spark versions

  #22 opened 8 years ago by dwestheide
  0

• Restructuring: Split up operators and syntax

  #20 opened 8 years ago by dwestheide
  0

• Add `combineByKey` operator

  #6 opened 8 years ago by dwestheide
  0

• Add `++` operator for concatenating two DCollections

  #5 opened 8 years ago by dwestheide
  0

• Add `collectAsMap` action

  #4 opened 8 years ago by dwestheide
  0

• Add additional `groupBy` operators

  #10 opened 8 years ago by dwestheide
  0

• Add scalafmt configuration

  #8 opened 8 years ago by dwestheide
  0

• Implement `keyBy` operator

  #9 opened 8 years ago by dwestheide
  0

• Add `mapPartitions` operator

  #12 opened 8 years ago by dwestheide
  0

• Allow choosing a join strategy (shuffle vs. map-side)

  #7 opened 8 years ago by dwestheide
  0

• Add support for broadcast variables

  #3 opened 8 years ago by dwestheide
  0