| bf1d877 | Robert Metzger | 13 February 2015, 08:17:51 UTC | Commit for release 0.8.1 | 13 February 2015, 08:17:51 UTC |
| 65338cf | Robert Metzger | 12 February 2015, 18:26:49 UTC | [build system] Add rat ignores for generated files | 12 February 2015, 18:26:49 UTC |
| 90ab2bb | Till Rohrmann | 12 February 2015, 16:37:11 UTC | [avro] Cleaning up project structure Updates .gitignore to ignore generated files | 12 February 2015, 17:21:08 UTC |
| a669d78 | Till Rohrmann | 12 February 2015, 15:50:46 UTC | [FLINK-1531] [runtime] Adds proper EOFException forwarding to KryoSerializer. Conflicts: flink-java/src/test/java/org/apache/flink/api/java/typeutils/runtime/KryoGenericTypeSerializerTest.java | 12 February 2015, 16:09:37 UTC |
| 10f89c7 | Robert Metzger | 12 February 2015, 11:32:27 UTC | [FLINK-1391] Register common Avro types at Kryo | 12 February 2015, 13:46:46 UTC |
| e7c9996 | Robert Metzger | 11 February 2015, 08:51:12 UTC | [FLINK-1510] Make AvroInputFormat splittable Conflicts: flink-runtime/src/main/java/org/apache/flink/runtime/fs/hdfs/HadoopDataInputStream.java flink-runtime/src/main/java/org/apache/flink/runtime/fs/s3/S3DataInputStream.java | 12 February 2015, 13:46:46 UTC |
| bab2d49 | Stephan Ewen | 12 February 2015, 09:48:32 UTC | Update LICENSE and NOTICE files for release 0.8.1 | 12 February 2015, 09:48:32 UTC |
| 5a5ec52 | twalthr | 26 January 2015, 15:09:24 UTC | [FLINK-1437][Java API] Fixes copy() methods in PojoSerializer for null values This closes #342 | 12 February 2015, 08:39:17 UTC |
| 68a0478 | Stephan Ewen | 11 February 2015, 20:44:37 UTC | [FLINK-1411] Fix standalone plan visualizer | 11 February 2015, 21:07:59 UTC |
| 79da5a9 | Stephan Ewen | 11 February 2015, 18:08:21 UTC | [FLINK-1492] [FLINK-1513] Fix BLOB service shutdown message and avoid global configuration | 11 February 2015, 20:06:54 UTC |
| 689e26f | Stephan Ewen | 09 February 2015, 13:01:10 UTC | [FLINK-1438] [jobmanager] Fix class loading issue for messages with custom input splits | 11 February 2015, 19:56:42 UTC |
| 5b420d8 | Ufuk Celebi | 09 February 2015, 10:44:47 UTC | [FLINK-1492] Fix exceptions on blob store shutdown Conflicts: flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobCache.java flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobServer.java flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobUtils.java | 10 February 2015, 13:40:35 UTC |
| e017121 | mbalassi | 09 February 2015, 14:59:03 UTC | [streaming] Small backport fixes for streaming to branch-0.8 Fix for operators inheriting lower parallelism e01057e Hash join for streaming joins 6d49d1d | 09 February 2015, 21:54:53 UTC |
| 6afa4ba | Aljoscha Krettek | 09 February 2015, 16:10:54 UTC | [hotfix] Fix missing guava dependency of flink-tests When building in hadoop 2 profile everything is fine since we get guava as a transitive dependency. For hadoop 1 we need to manually add the guava dependency. This was erroneously removed earlier. | 09 February 2015, 16:46:44 UTC |
| cd2f88a | Aljoscha Krettek | 28 January 2015, 14:13:30 UTC | [FLINK-1396][FLINK-1303] Hadoop Input/Output directly in API This adds methods on ExecutionEnvironment for reading with Hadoop Input/OutputFormat. This also adds support in the Scala API for Hadoop Input/OutputFormats. | 09 February 2015, 14:38:06 UTC |
| 944e2e3 | Robert Metzger | 05 February 2015, 13:07:48 UTC | [backports] Cleanup and port changes to 0.8 branch. | 09 February 2015, 13:48:34 UTC |
| 95958a9 | Aljoscha Krettek | 15 January 2015, 10:46:53 UTC | [hotfix] Also use java closure cleaner on grouped operations | 09 February 2015, 13:48:34 UTC |
| c4c3db5 | Robert Metzger | 13 January 2015, 09:21:29 UTC | [FLINK-1392] Add Kryo serializer for Protobuf Conflicts: flink-java/pom.xml flink-java/src/main/java/org/apache/flink/api/java/typeutils/runtime/KryoSerializer.java Conflicts: flink-shaded/pom.xml pom.xml | 09 February 2015, 13:48:34 UTC |
| 84c4998 | Robert Metzger | 12 January 2015, 20:11:09 UTC | [FLINK-1391] Add support for using Avro-POJOs and Avro types with Kryo Conflicts: flink-java/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java flink-java/src/main/java/org/apache/flink/api/java/typeutils/runtime/KryoSerializer.java Conflicts: flink-java/src/main/java/org/apache/flink/api/java/typeutils/runtime/KryoSerializer.java | 09 February 2015, 13:48:34 UTC |
| 02b6f85 | Aljoscha Krettek | 30 January 2015, 15:43:31 UTC | [FLINK-1463] Fix stateful/stateless Serializers and Comparators Before, Serializers would announce whether they are stateful or not and rely on RuntimeStatefulSerializerFactory to do the duplication. Comparators, on the other hand, had a duplicate method that the user was required to call. This commit removes the statful/stateless property from Serializers but instead introduces a duplicate() method, similar to Comparators, that can return the same instance. The two serializer factories are merged into one that always calls duplicate() before returning a serializer. | 09 February 2015, 13:20:23 UTC |
| 91382bb | Till Rohrmann | 12 January 2015, 09:58:45 UTC | [FLINK-1376] [runtime] Add proper shared slot release in case of a fatal TaskManager failure. Fixes concurrent modification exception of SharedSlot's subSlots field by synchronizing all state changing operations through the associated assignment group. Fixes deadlock where Instance.markDead first acquires InstanceLock and then by releasing the associated slots the assignment group lockcan block with a direct releaseSlot call on a SharedSlot which first acquires the assignment group lock and then the instance lock in order to return the slot to the instance. Fixes colocation shared slot releasing. A colocation constraint is now realized as a SharedSlot in a SharedSlot where the colocated tasks allocate sub slots. | 09 February 2015, 12:25:30 UTC |
| 44b799d | Stephan Ewen | 05 February 2015, 13:09:51 UTC | [FLINK-1479] [runtime] Spawned threads in sorter get the same context class loader as the parent thread | 09 February 2015, 12:23:27 UTC |
| aca6210 | Alexander Alexandrov | 06 February 2015, 14:23:02 UTC | Remove 'incubator-' prefix from README.md. This closes #371 | 06 February 2015, 16:25:44 UTC |
| a44c721 | mbalassi | 06 February 2015, 16:12:29 UTC | [docs] Updated legacy references containing 'incubator' substring Also dumped the stable release version in the docs config Conflicts: docs/_config.yml | 06 February 2015, 16:25:39 UTC |
| d40fe0a | Gyula Fora | 06 February 2015, 11:30:30 UTC | [streaming] Critical bugfix for streaming keyselectors | 06 February 2015, 16:24:08 UTC |
| f68bfb8 | Ufuk Celebi | 05 February 2015, 10:48:16 UTC | Log blob cache and server storage directories at startup | 05 February 2015, 11:00:14 UTC |
| 766191f | Ufuk Celebi | 05 February 2015, 10:47:37 UTC | Ensure blob manager storage directory creation is successful | 05 February 2015, 10:58:25 UTC |
| 2387a08 | Robert Metzger | 25 January 2015, 15:05:20 UTC | [FLINK-1433] Add HADOOP_CLASSPATH to start scripts This closes #337 Conflicts: flink-dist/src/main/flink-bin/bin/jobmanager.sh flink-dist/src/main/flink-bin/bin/taskmanager.sh flink-dist/src/main/flink-bin/bin/webclient.sh | 27 January 2015, 11:23:03 UTC |
| 8ca7cba | Robert Metzger | 26 January 2015, 15:26:36 UTC | [FLINK-1446] Fix Kryo createInstance() method | 26 January 2015, 15:26:36 UTC |
| 11f4a65 | FelixNeutatz | 26 January 2015, 11:53:38 UTC | [FLINK-1428] [docs] Fix typos in Java code example for RichGroupReduceFunction [ci skip] This closes #340. | 26 January 2015, 12:41:23 UTC |
| 00117f7 | Robert Metzger | 12 January 2015, 15:40:34 UTC | [FLINK-1389] Allow changing the filenames of the files created when writing to a directory This closes #301 | 26 January 2015, 10:30:32 UTC |
| cd96caf | Stephan Ewen | 24 January 2015, 21:01:25 UTC | [FLINK-1440] [docs] Fix missing plan visualizer image. | 24 January 2015, 21:22:54 UTC |
| 1826dee | Robert Metzger | 21 January 2015, 20:55:00 UTC | [docs] Update URLs for the release | 21 January 2015, 20:55:00 UTC |
| eacbccf | Gyula Fora | 07 January 2015, 15:30:09 UTC | [FLINK-1367] [scala] [streaming] Field aggregations added to streaming scala api | 21 January 2015, 15:09:23 UTC |
| 8c8d86a | Carsten Brandt | 21 January 2015, 08:35:36 UTC | [Docs] Fix typo in programming guide This closes #327. | 21 January 2015, 10:50:20 UTC |
| 52a8f6c | Ufuk Celebi | 15 January 2015, 16:22:40 UTC | [FLINK-1183] Generate gentle notification message when Flink is started with Java 6 (backport) | 15 January 2015, 16:22:40 UTC |
| 4c6f944 | mbalassi | 14 January 2015, 21:31:17 UTC | Commit for year 2015 Updated NOTICE files Updated inceptionYear in pom | 15 January 2015, 08:09:37 UTC |
| 7b8ef0d | mbalassi | 18 December 2014, 18:00:33 UTC | [build tools] Release script update Default hadoop version is now hadoop2 Generate specific pom avoids version collisions with dependencies Updated poms for new release scripts | 15 January 2015, 08:09:25 UTC |
| b58a0aa | mbalassi | 14 January 2015, 10:41:13 UTC | Fix for quickstart versions | 14 January 2015, 10:46:10 UTC |
| f97a994 | Robert Metzger | 13 January 2015, 20:55:00 UTC | [FLINK-1397] Fix logfile access from JobManager web interface | 14 January 2015, 09:39:25 UTC |
| b4e9db0 | mbalassi | 12 January 2015, 09:50:55 UTC | [dist] Updated mailing list info in binary distribution | 12 January 2015, 09:50:55 UTC |
| 4f95ce7 | Ufuk Celebi | 09 January 2015, 13:54:57 UTC | Fix typo in README.md | 12 January 2015, 08:57:33 UTC |
| a64abe1 | Stephan Ewen | 08 January 2015, 17:32:22 UTC | [docs] Update README and internals (scheduling) for graduation and fix broken links Conflicts: README.md docs/internal_job_scheduling.md | 12 January 2015, 08:57:33 UTC |
| e83ccd0 | Robert Metzger | 10 January 2015, 17:20:10 UTC | [FLINK-1385] Print warning if not resources are _currently_ available in the YARN cluster. Instead of rejecting the session This closes #294 | 12 January 2015, 08:57:33 UTC |
| 7cd0f47 | Robert Metzger | 10 January 2015, 11:21:56 UTC | [docs] Prepare documentation for 0.8 release | 12 January 2015, 08:57:32 UTC |
| ada35eb | Aljoscha Krettek | 09 January 2015, 18:31:05 UTC | [FLINK-1378] [scala] Add support for Try[A] (Success/Failure) | 11 January 2015, 21:24:38 UTC |
| fced2eb | Aljoscha Krettek | 09 January 2015, 18:04:23 UTC | [FLINK-1378] Add support for Throwables in KryoSerializer | 11 January 2015, 20:48:03 UTC |
| 4f9dcae | Aljoscha Krettek | 09 January 2015, 16:11:17 UTC | [FLINK-1378] [scala] Fix type extraction for nested type parameters Before, something like: def f[T: TypeInformation](data: DataSet[T]) = { val tpe = createTypeInformation[(T, Seq[T])] println("Type: " + tpe) } f(Seq(1.0f, 2.0f) would fail because the type extractor could not re-use existing TypeInformation for nested types. | 11 January 2015, 20:46:20 UTC |
| 3da8751 | Stephan Ewen | 11 January 2015, 19:08:28 UTC | [FLINK-1386] [quickstart] Fix pom in java quickstart archetype | 11 January 2015, 19:31:40 UTC |
| ae5864a | mbalassi | 10 January 2015, 18:56:29 UTC | [FLINK-1358] [streaming] Streaming added to the quickstarts | 11 January 2015, 19:30:58 UTC |
| f360b07 | Stephan Ewen | 10 January 2015, 17:37:37 UTC | [LICENSE] Update LICENSE and NOTICE files - Add missing entries for dependencies - Remove entries for removed dependencies - Change DEPENDENCIES file to point to src and bin LICENSE and NOTICE file - Add comments in some files to clarify whether the are Flink original, or from which third party file they are adapted - Change some links from incubator to TLP | 10 January 2015, 17:48:02 UTC |
| cebd628 | Stephan Ewen | 10 January 2015, 17:37:09 UTC | [tachyon] Minor fix in codestyle and warnings | 10 January 2015, 17:42:21 UTC |
| d707dca | Stephan Ewen | 10 January 2015, 17:28:01 UTC | Minor dependencies cleanup: - Move sling JSON dependency to streaming connectors (prev streaming core) - Exclude YARN API from transitive mapreduce-core dependencies we use the dependency only for .mapred and .mapreduce interfaces - Remove some unnecessary dependencies (junit in java8) - Manage Kryo dependency - Cleanup minor POM warnings. | 10 January 2015, 17:42:21 UTC |
| 8b31e12 | Stephan Ewen | 10 January 2015, 17:18:48 UTC | [FLINK-1384] [webfrontend] Remove unused JS libraries | 10 January 2015, 17:42:21 UTC |
| fb769d2 | Stephan Ewen | 10 January 2015, 16:23:57 UTC | [docs] Add FAQ entry about scala implicits error when missing imports | 10 January 2015, 17:42:21 UTC |
| 66414c3 | Stephan Ewen | 10 January 2015, 16:22:57 UTC | [docs] Clean up documentation figures - Remove old unused figure image files - Add a file clarifying that figures are licensed under ASL 2.0 | 10 January 2015, 17:41:34 UTC |
| e8bc518 | Stephan Ewen | 09 January 2015, 17:13:27 UTC | [FLINK-1375] [assembly] Remove incubator DISCLAIMER file from binary distribution | 09 January 2015, 17:13:27 UTC |
| e8ab5b7 | Robert Metzger | 09 January 2015, 15:53:46 UTC | [FLINK-1266] Backport fix to 0.8 | 09 January 2015, 15:53:46 UTC |
| 3bf2d21 | Robert Metzger | 08 January 2015, 14:24:46 UTC | [FLINK-1266] More dependency exclusions This closes #268 | 08 January 2015, 17:02:01 UTC |
| cd66ced | Robert Metzger | 08 January 2015, 11:28:06 UTC | [FLINK-1266] Properly pass the fs.defaulFS setting when initializing filesystems | 08 January 2015, 12:50:26 UTC |
| 40a2705 | Robert Metzger | 05 January 2015, 13:15:21 UTC | [FLINK-1266] Update mongodb link and address pull request comments Conflicts: pom.xml | 08 January 2015, 12:47:49 UTC |
| 7634310 | Robert Metzger | 12 December 2014, 15:45:02 UTC | [FLINK-1266] Generalize DistributedFileSystem implementation to HadoopFileSystem wrapper, which supports all subclasses of org.apache.hadoop.fs.FileSystem. This allows us to let users use all file systems with support for HDFS. The change has been tested with Tachyon, Google Cloud Storage Hadoop Adapter and HDFS. The change also cleans up the Hadoop dependency exclusions. Conflicts: flink-addons/flink-hadoop-compatibility/pom.xml | 08 January 2015, 12:42:21 UTC |
| d533ddc | Stephan Ewen | 08 January 2015, 11:38:51 UTC | [FLINK-1371] [runtime] Fix KryoSerializer to not swallow EOFExceptions | 08 January 2015, 11:53:18 UTC |
| 242ff64 | Gyula Fora | 07 January 2015, 09:24:00 UTC | [streaming] Replaced partitionBy with groupBy + re-added global partitioning | 07 January 2015, 12:57:48 UTC |
| 80ff884 | mbalassi | 06 January 2015, 21:50:18 UTC | [streaming] [scala] scala SocketTextStream added and minor fixes Organized imports for streaming scala examples Added template parameter for scala streaming iterate Minor fixes in streaming examples | 07 January 2015, 10:51:00 UTC |
| b2f6df7 | carbone | 06 January 2015, 12:53:01 UTC | [scala] [streaming] added scala streams as sources in streaming-api scala examples | 06 January 2015, 14:48:05 UTC |
| 544b924 | Gyula Fora | 06 January 2015, 11:05:22 UTC | [scala] [streaming] Added package file for streaming scala api typeinfo implicits and conversions | 06 January 2015, 14:47:53 UTC |
| acd2d60 | Gyula Fora | 05 January 2015, 17:26:18 UTC | [streaming] Updated streaming guide for recent connector and data source changes | 05 January 2015, 23:22:58 UTC |
| fcd28fc | Gyula Fora | 05 January 2015, 14:59:50 UTC | [streaming] Deleted obsolete parts of the connected stream api | 05 January 2015, 23:22:58 UTC |
| fb86fde | Gyula Fora | 05 January 2015, 14:24:59 UTC | [streaming] Temporal operator windowing syntax update Conflicts: flink-addons/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/WindowCrossJoinTest.java | 05 January 2015, 23:22:57 UTC |
| e3700c3 | Stephan Ewen | 04 January 2015, 22:09:26 UTC | [docs] Remove files from obolete and unused figures | 05 January 2015, 23:22:57 UTC |
| e78c453 | Stephan Ewen | 04 January 2015, 22:08:55 UTC | [FLINK-1338] [docs] Remove incubator footer from docs | 05 January 2015, 23:22:57 UTC |
| 232b0eb | Erich Schubert | 02 January 2015, 18:56:57 UTC | [docs] Trivial typo in example code: o -> out. This closes #280 | 05 January 2015, 23:13:08 UTC |
| bf85c00 | mbalassi | 04 January 2015, 11:44:16 UTC | [streaming] [scala] Restructured streaming scala project and examples Amended for the release-0.8 branch | 05 January 2015, 23:12:59 UTC |
| 380934b | Gyula Fora | 25 December 2014, 17:00:26 UTC | [streaming] Updated connector type handling to suport generic classes by GenericSourceFunction interface | 05 January 2015, 17:08:54 UTC |
| e0fd9df | Gyula Fora | 23 December 2014, 21:13:22 UTC | [streaming] Source parallelism + connector rework | 05 January 2015, 17:07:50 UTC |
| 7eaf726 | carbone | 03 January 2015, 19:00:13 UTC | [scala] [streaming] Added connect op to DataStream and implicit conversion for ConnectedDataStreams [scala] [streaming] Changed return types to implicits | 05 January 2015, 17:07:21 UTC |
| b094d49 | carbone | 03 January 2015, 18:46:22 UTC | [scala] [streaming] added initial ConnectedDataStream support (no windowing,batching) for the scala api | 05 January 2015, 17:07:08 UTC |
| e1fa9b5 | senorcarbone | 02 January 2015, 10:15:49 UTC | [scala] [streaming] added group windowing example with different policy types [scala] [streaming] updated example with scala delta helper usage | 05 January 2015, 17:06:38 UTC |
| c34f5a7 | Gyula Fora | 03 January 2015, 18:41:37 UTC | [scala] [streaming] Added implicit conversions from java to scala streams | 05 January 2015, 17:06:19 UTC |
| 1492e96 | Gyula Fora | 02 January 2015, 19:04:51 UTC | [scala] [streaming] Added scala window helpers + timestamp rework for lambda support Conflicts: flink-addons/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/WindowCrossJoinTest.java | 05 January 2015, 17:05:58 UTC |
| 5995248 | Gyula Fora | 23 December 2014, 20:16:46 UTC | [streaming] Streaming API grouping rework to use batch api Keys Conflicts: flink-addons/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/util/ClusterUtil.java | 05 January 2015, 17:04:17 UTC |
| c6b90ee | Gyula Fora | 21 December 2014, 12:10:34 UTC | [scala] [streaming] WindowJoin scala example added | 05 January 2015, 16:59:57 UTC |
| 1413484 | Gyula Fora | 21 December 2014, 02:54:30 UTC | [scala] [streaming] Added groupBy support for case class fields | 05 January 2015, 16:59:43 UTC |
| 1f7b6ea | Gyula Fora | 21 December 2014, 00:05:40 UTC | [scala] [streaming] Fixed scala formatting | 05 January 2015, 16:58:54 UTC |
| f7291ea | Gyula Fora | 20 December 2014, 22:46:35 UTC | [scala] [streaming] Modified aggregations to work on scala tuples | 05 January 2015, 16:57:44 UTC |
| 40a3b6b | Gyula Fora | 20 December 2014, 18:34:55 UTC | [scala] [streaming] Temporal cross operator added | 05 January 2015, 16:57:08 UTC |
| 739fdf0 | Gyula Fora | 20 December 2014, 17:12:19 UTC | [scala] [streaming] Temporal join operator added | 05 January 2015, 16:56:49 UTC |
| 652327b | Gyula Fora | 19 December 2014, 20:05:01 UTC | [streaming] Temporal join and cross rework for consistence and extended features | 05 January 2015, 16:54:26 UTC |
| 1922dbd | Gyula Fora | 18 December 2014, 21:46:00 UTC | [scala] [streaming] Added support for iterative streams for scala api | 05 January 2015, 16:53:54 UTC |
| a4c4f26 | mbalassi | 15 December 2014, 13:15:35 UTC | [scala] [streaming] Added SplitDataStream functionality Conflicts: flink-scala/src/main/scala/org/apache/flink/api/scala/streaming/DataStream.scala | 05 January 2015, 16:53:28 UTC |
| e0ab489 | Gyula Fora | 15 December 2014, 15:21:00 UTC | [scala] [streaming] Windowing functionality added to scala api | 05 January 2015, 16:52:46 UTC |
| d1b53b1 | Gyula Fora | 13 December 2014, 00:08:08 UTC | [scala] [streaming] Finished scala StreamExecutionEnvrionment functionality + DataStream sinks + docs Conflicts: flink-addons/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/WriteAsCsvTest.java flink-addons/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/WriteAsTextTest.java | 05 January 2015, 16:51:45 UTC |
| 40efecf | Gyula Fora | 11 December 2014, 23:12:49 UTC | [scala] [streaming] Extended scala data stream functionality to include simple operators | 05 January 2015, 16:49:30 UTC |
| 6b1fd15 | Gyula Fora | 11 December 2014, 14:22:03 UTC | [scala] [streaming] Base functionality added for streaming scala api Conflicts: flink-addons/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java | 05 January 2015, 16:49:00 UTC |
| b2271bd | Gyula Fora | 02 January 2015, 17:33:46 UTC | [streaming] Time trigger preNotify fix | 04 January 2015, 21:11:13 UTC |
| 2467f36 | mbalassi | 26 December 2014, 17:06:51 UTC | [streaming] Temporal fix for streaming source parallelism | 26 December 2014, 17:06:51 UTC |
| 6b3c3a1 | mbalassi | 26 December 2014, 17:02:55 UTC | [FLINK-1225] Fix for quickstart packaging This closes #279 | 26 December 2014, 17:02:55 UTC |
| 9555c82 | mbalassi | 19 December 2014, 22:34:02 UTC | [FLINK-1338] Updates necessary due to Apache graduation Removed Disclaimer file Eliminated unnecessary incubating substrings Bumped version to 0.8-SNAPSHOT | 20 December 2014, 08:35:38 UTC |
| cadc9cc | Jonas Traub (powibol) | 18 December 2014, 15:11:16 UTC | [streaming] Make windowed data stream aware of time based trigger/eviction in tumbling window situations. [streaming] Changed TimeEvictionPolicy to keep timestamps in the buffer instead of data-items | 18 December 2014, 17:53:30 UTC |
