- 08 1月, 2015 8 次提交
-
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
- The map driver now also supports this - In the merge iterator (merges sorted runs from external sort), we now always use the non-reusing code path, because the reusing codepath here implies in all cases additional instances to be held concurrently, and copy between elements, which voids the benefits of reusing elements. - For many utility iterators (in test cases), consolidates the logic between the two variants of the "next()" functions (one calls the other, where possible) - Eliminates a few copies between elements in the non-reusing parts (where possible) - Removes unused variables in the non-reusing variants (mainly serializers previously used to create instance or copy between instances) - Remove some unused types - Improves generic type safety (fewer raw types)
-
由 Aljoscha Krettek 提交于
This closes #259
-
由 Aljoscha Krettek 提交于
-
由 Aljoscha Krettek 提交于
This is in preparation for configurable object-reuse mode. We previously referred to this as mutable object vs. mutable object safe mode or some such thing.
-
由 Kostas Tzoumas 提交于
This closes #285
-
由 Max 提交于
This closes #286
-
- 07 1月, 2015 3 次提交
-
-
由 Aljoscha Krettek 提交于
-
由 Aljoscha Krettek 提交于
-
由 Till Rohrmann 提交于
[FLINK-1363] [runtime tests] Fix race condition in ExecutionVertexCancelTest.testSendCancelAndReceiveFail This closes #288
-
- 06 1月, 2015 16 次提交
-
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
[FLINK-1259] [apis] Added comments to interface and docs that filters must not mutate date elements.
-
由 Stephan Ewen 提交于
-
由 carbone 提交于
-
由 Gyula Fora 提交于
-
由 Gyula Fora 提交于
-
由 Gyula Fora 提交于
-
由 Gyula Fora 提交于
-
由 Fabian Hueske 提交于
This closes #267
-
由 Alexander Alexandrov 提交于
This closes #278
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
- Remove obsolete code from old IPC net utils - Smaller Writable/IOReadableWritable serialzation buffer start size (most messages are rather small) - For message logging, make system calls (timestamps) only in debug mode - Clean up warnings / code simplifications
-
由 Henry Saputra 提交于
Simple code cleanup to remove full package name for FlatMapOperatorBase for FlatMapOperator#translateToDataFlow method Author: Henry Saputra <hsaputra@apache.org> Closes #272 from hsaputra/remove_packagepath_flatmapoperatorbase and squashes the following commits: 8ce5abd [Henry Saputra] Remove full package name for FlatMapOperatorBase for FlatMapOperator#translateToDataFlow method.
-
- 05 1月, 2015 6 次提交
-
-
由 Stephan Ewen 提交于
[FLINK-1335] [docs] Update internals with brief description about JobManager data structures and scheduling. This closes #281
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Erich Schubert 提交于
This closes #280
-
由 mbalassi 提交于
This closes #275
-
- 04 1月, 2015 6 次提交
-
-
由 Gyula Fora 提交于
[streaming] Updated connector type handling to suport generic classes by GenericSourceFunction interface
-
由 Gyula Fora 提交于
-
由 carbone 提交于
[scala] [streaming] Changed return types to implicits
-
由 carbone 提交于
[scala] [streaming] added initial ConnectedDataStream support (no windowing,batching) for the scala api
-
由 senorcarbone 提交于
[scala] [streaming] updated example with scala delta helper usage
-
由 Gyula Fora 提交于
-
- 03 1月, 2015 1 次提交
-
-
由 Gyula Fora 提交于
-