seznam/euphoria

Issues

• Running example with flink

  #285 opened 7 years ago by kination
  13

• [DISCUSS]: stateful operations should have only single storage provider

  #128 opened 6 years ago by je-ik
  4

• Add stateful mapping

  #192 opened 6 years ago by je-ik
  1

• euphoria-core: Consider adding support for side-outputs

  #124 opened 6 years ago by vanekjar
  1

• Implement beam runtime

  #152 opened 6 years ago by dmvk
  1

• TImeSliding window has no early emitting

  #245 opened 6 years ago by je-ik
  1

• Upgrade dependencies (flink, spark, kafka)

  #175 opened 6 years ago by je-ik
  1

• Implement splitting in bounded sources

  #191 opened 6 years ago by je-ik
  1

• Remap in place values on call to output() in grouping operations

  #194 opened 6 years ago by je-ik
  2

• Sinks must be aware of windows

  #204 opened 6 years ago by je-ik
  1

• GlobalWindowing has no early emitting

  #246 opened 6 years ago by je-ik
  1

• Refactor outputs as stateful operators

  #256 opened 6 years ago by je-ik
  1

• ConcurrentModificationException in unboudned stream

  #261 opened 7 years ago by cervebar
  1

• Make logging facility usage consistent

  #266 opened 6 years ago by je-ik
  1

• Rework DAG representation

  #273 opened 6 years ago by je-ik
  1

• Why it is named as 'HadoopTextFileSource'

  #284 opened 6 years ago by kination
  2

• Running with LocalExecutor

  #275 opened 7 years ago by kination
  8

• Has some plans supporting Flink SQL ?

  #258 opened 7 years ago by lynchlee
  3

• Hints should not be runtime specific and should describe data only

  #259 opened 7 years ago by dmvk
  1

• UnboundedDataSource has no way of reporting stream error

  #262 opened 7 years ago by slechta
  2

• Local executor checkpointing

  #263 opened 7 years ago by dmvk
  1

• Flink - broadcast hash join

  #260 opened 7 years ago by dmvk
  0

• euphoria-local: Allowing persist of intermediate dataset

  #255 opened 7 years ago by t-novak
  6

• Feature: Minor: allow window to be assigned in `FlatMap`

  #122 opened 7 years ago by je-ik
  2

• Add parallelism control

  #228 opened 7 years ago by je-ik
  1

• Flipping test

  #226 opened 7 years ago by dmvk
  0

• Support for hints in operator testkit.

  #210 opened 7 years ago by dmvk
  0

• Add HBase module

  #181 opened 7 years ago by je-ik
  1

• Exception in LocalExecutor during running should propagate to Result

  #201 opened 7 years ago by je-ik
  0

• euphoria-core: Add access to timestamp and key to context

  #131 opened 8 years ago by je-ik
  0

• Change Iterable to Stream in reducing operations

  #161 opened 7 years ago by je-ik
  1

• euphoria-inmem: race between element and watermark emission

  #129 opened 7 years ago by xitep
  1

• Distinguish stream and batch inputs

  #156 opened 7 years ago by je-ik
  1

• Completely remove time triggers from batch processing

  #190 opened 7 years ago by je-ik
  0

• Introduce MultiDataSink

  #177 opened 7 years ago by dmvk
  0

• Rename InMemExecutor to LocalExecutor

  #173 opened 7 years ago by je-ik
  1

• Outputs have to have option to modify the Flow

  #157 opened 7 years ago by je-ik
  1

• Extend `ReduceByKey` operator with value sorting

  #158 opened 7 years ago by je-ik
  1

• Benchmarks are not part of the build

  #167 opened 7 years ago by je-ik
  0

• Travis build is failing

  #159 opened 7 years ago by je-ik
  1

• Drop explicit partitioning

  #160 opened 7 years ago by je-ik
  1

• euphoria-core: Sort per partition

  #155 opened 7 years ago by t-novak
  2

• Remove DataSourceFactory

  #147 opened 7 years ago by dmvk
  2

• Complete join semantics

  #143 opened 7 years ago by je-ik
  0

• Feature: support data driven triggers

  #140 opened 7 years ago by je-ik
  0

• Accumulators: Implement support for Spark native accumulators

  #134 opened 7 years ago by vanekjar
  0

• Accumulators: Unit testing of accumulators

  #135 opened 7 years ago by vanekjar
  0

• Accumulators: Integrate Accumulator API with all available executors

  #133 opened 7 years ago by vanekjar
  0

• Improvement: introduce rich functions

  #136 opened 8 years ago by je-ik
  0

• Feature: allow multiple elements to be emitted from ReduceByKey

  #121 opened 8 years ago by je-ik
  1