提交 · e1f8581b4ab29f0f28bf21c4e4d9fa43d926d94a · doujutun3207 / flink

08 1月, 2015 1 次提交
- M
  [FLINK-1361] change jobManager log file name back to old value · e1f8581b
  由 Max 提交于 1月 06, 2015
```
This closes #286
```
  e1f8581b
07 1月, 2015 3 次提交
- A
  
  [FLINK-1366] Enable FastPath in TextValueInputFormat again · 383ae265
  由 Aljoscha Krettek 提交于 12月 05, 2014
  
  383ae265
- A
  
  [FLINK-1365] Fix ValueTypeInfo · 59970361
  由 Aljoscha Krettek 提交于 12月 18, 2014
  
  59970361
- T
  [FLINK-1363] [runtime tests] Fix race condition in... · 47ec09e1
  由 Till Rohrmann 提交于 1月 07, 2015
```
[FLINK-1363] [runtime tests] Fix race condition in ExecutionVertexCancelTest.testSendCancelAndReceiveFail

This closes #288
```
  47ec09e1
06 1月, 2015 16 次提交
- S
  
  [FLINK-1169] [apis] Add documentation for join hints. · c52f4cab
  由 Stephan Ewen 提交于 1月 06, 2015
  
  c52f4cab
- S
  [FLINK-1259] [apis] Added comments to interface and docs that filters must not... · e71ee0b7
  由 Stephan Ewen 提交于 1月 06, 2015
```
[FLINK-1259] [apis] Added comments to interface and docs that filters must not mutate date elements.
```
  e71ee0b7
- S
  
  [FLINK-1300] [core] Remove unused and redundant files DataInputViewStream and DataOutputViewStream. · 875c6aac
  由 Stephan Ewen 提交于 1月 06, 2015
  
  875c6aac
- C
  
  [scala] [streaming] added scala streams as sources in streaming-api scala examples · baf81c6c
  由 carbone 提交于 1月 06, 2015
  
  baf81c6c
- G
  
  [scala] [streaming] Added package file for streaming scala api typeinfo implicits and conversions · 5daa45c2
  由 Gyula Fora 提交于 1月 06, 2015
  
  5daa45c2
- G
  
  [streaming] Updated streaming guide for recent connector and data source changes · 8500ad08
  由 Gyula Fora 提交于 1月 05, 2015
  
  8500ad08
- G
  
  [streaming] Deleted obsolete parts of the connected stream api · 11518b58
  由 Gyula Fora 提交于 1月 05, 2015
  
  11518b58
- G
  
  [streaming] Temporal operator windowing syntax update · b0a2e4a1
  由 Gyula Fora 提交于 1月 05, 2015
  
  b0a2e4a1
- F
  [FLINK-1236] [hadoop compatibility] Add local split assignment support for HadoopInputFormats · 92ceacd2
  由 Fabian Hueske 提交于 12月 15, 2014
```
This closes #267
```
  92ceacd2
- A
  [FLINK-1027] [cli] Added support for '--' and '-' prefixed tokens in CLI program arguments. · 93eadca7
  由 Alexander Alexandrov 提交于 12月 24, 2014
```
This closes #278
```
  93eadca7
- S
  
  [FLINK-1357] [compiler] Add union between static and dynamic path · 0190dd24
  由 Stephan Ewen 提交于 12月 18, 2014
  
  0190dd24
- S
  
  [FLINK-1335] [docs] Minor fix to README file · d2f0c405
  由 Stephan Ewen 提交于 1月 06, 2015
  
  d2f0c405
- S
  
  [FLINK-1335] [docs] Add guide how to set up Eclipse, and bring README.md up to speed. · 2b86e953
  由 Stephan Ewen 提交于 1月 06, 2015
  
  2b86e953
- S
  
  [FLINK-1349] [runtime] Various cleanups to make scala runtime code interact smoother with java · cec30ff4
  由 Stephan Ewen 提交于 1月 06, 2015
  
  cec30ff4
- S
  [FLINK-1349] [runtime] Various fixes concerning Akka · 972a7b01
  由 Stephan Ewen 提交于 12月 28, 2014
```
 - 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
```
  972a7b01
- H
  Remove full package name for FlatMapOperatorBase · 24c47362
  由 Henry Saputra 提交于 1月 05, 2015
```
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.
```
  24c47362
05 1月, 2015 6 次提交
- S
  [FLINK-1335] [docs] Update internals with brief description about JobManager... · 4895131e
  由 Stephan Ewen 提交于 1月 05, 2015
```
[FLINK-1335] [docs] Update internals with brief description about JobManager data structures and scheduling.

This closes #281
```
  4895131e
- S
  
  [FLINK-1346] [docs] Add stubs for Akka documentation · d2691d2e
  由 Stephan Ewen 提交于 1月 04, 2015
  
  d2691d2e
- S
  
  [docs] Remove files from obolete and unused figures · 6167fcc1
  由 Stephan Ewen 提交于 1月 04, 2015
  
  6167fcc1
- S
  
  [FLINK-1338] [docs] Remove incubator footer from docs · f330f1cf
  由 Stephan Ewen 提交于 1月 04, 2015
  
  f330f1cf
- E
  [docs] Trivial typo in example code: o -> out. · f71b0c42
  由 Erich Schubert 提交于 1月 02, 2015
```
This closes #280
```
  f71b0c42
- M
  [streaming] [scala] Restructured streaming scala project and examples · 8183c8c3
  由 mbalassi 提交于 1月 04, 2015
```
This closes #275
```
  8183c8c3
04 1月, 2015 6 次提交
- G
  [streaming] Updated connector type handling to suport generic classes by... · 3f1af0e3
  由 Gyula Fora 提交于 12月 25, 2014
```
[streaming] Updated connector type handling to suport generic classes by GenericSourceFunction interface
```
  3f1af0e3
- G
  
  [streaming] Source parallelism + connector rework · 2425885c
  由 Gyula Fora 提交于 12月 23, 2014
  
  2425885c
- C
  [scala] [streaming] Added connect op to DataStream and implicit conversion for ConnectedDataStreams · b9d0241f
  由 carbone 提交于 1月 03, 2015
```
[scala] [streaming] Changed return types to implicits
```
  b9d0241f
- C
  [scala] [streaming] added initial ConnectedDataStream support (no... · 55ef7954
  由 carbone 提交于 1月 03, 2015
```
[scala] [streaming] added initial ConnectedDataStream support (no windowing,batching) for the scala api
```
  55ef7954
- S
  [scala] [streaming] added group windowing example with different policy types · a761cdcb
  由 senorcarbone 提交于 1月 02, 2015
```
[scala] [streaming] updated example with scala delta helper usage
```
  a761cdcb
- G
  
  [scala] [streaming] Added implicit conversions from java to scala streams · d4ec0095
  由 Gyula Fora 提交于 1月 03, 2015
  
  d4ec0095
03 1月, 2015 8 次提交
- G
  
  [scala] [streaming] Added scala window helpers + timestamp rework for lambda support · fac77348
  由 Gyula Fora 提交于 1月 02, 2015
  
  fac77348
- G
  
  [streaming] Streaming API grouping rework to use batch api Keys · 8bf9416d
  由 Gyula Fora 提交于 12月 23, 2014
  
  8bf9416d
- G
  
  [scala] [streaming] WindowJoin scala example added · 1d019b9b
  由 Gyula Fora 提交于 12月 21, 2014
  
  1d019b9b
- G
  
  [scala] [streaming] Added groupBy support for case class fields · a7519887
  由 Gyula Fora 提交于 12月 21, 2014
  
  a7519887
- G
  
  [scala] [streaming] Fixed scala formatting · 6f215b50
  由 Gyula Fora 提交于 12月 21, 2014
  
  6f215b50
- G
  
  [scala] [streaming] Modified aggregations to work on scala tuples · 75dd021a
  由 Gyula Fora 提交于 12月 20, 2014
  
  75dd021a
- G
  
  [scala] [streaming] Temporal cross operator added · e37ec793
  由 Gyula Fora 提交于 12月 20, 2014
  
  e37ec793
- G
  
  [scala] [streaming] Temporal join operator added · 555837cd
  由 Gyula Fora 提交于 12月 20, 2014
  
  555837cd

doujutun3207 / flink 与 Fork 源项目一致

doujutun3207 / flink
与 Fork 源项目一致