- 02 12月, 2015 5 次提交
-
-
由 Aljoscha Krettek 提交于
This also adds a test for asynchronous state handles.
-
由 Aljoscha Krettek 提交于
Before, it would not allow unioning with predecessors (also transitive) and streams of differing parallelism.
-
由 chengxiang li 提交于
-
由 Maximilian Michels 提交于
- refactor to use Storm's topology builder - remove FlinkTopologyBuilder - instantiate context-based StreamExecutionEnvironment (local or remote) - remove some of the Flink and Storm behavior replicating classes - modify FlinkTopology to parse Storm topology directly - replace StormTestBase with StreamingTestBase - add print example - FlinkTopologyBuilder changes (check if all inputs are available before processing) - correct package typo - two input support - add join example - update docs This closes #1398.
-
由 chengxiang li 提交于
-
- 01 12月, 2015 12 次提交
-
-
由 Maximilian Michels 提交于
The RabbitMQ source may operate in three different modes: 1) Exactly-once (when checkpointed) with RabbitMQ transactions and messages with unique correlation IDs. 2) At-least-once (when checkpointed) with RabbitMQ transactions but no deduplication mechanism (correlation id is not set). 3) No strong delivery guarantees (without checkpointing) with RabbitMQ auto-commit mode. - add base class which can handle both session ids and unique ids - session ids are used for acknowledgment - unique ids are used for de-duplication - add unit test - add documentation This closes #1243.
-
由 Hilmi Yildirim 提交于
-
由 Till Rohrmann 提交于
-
由 madhukar 提交于
This closes #1424.
-
由 Till Rohrmann 提交于
-
由 Stephan Ewen 提交于
This closes #1423
-
由 Fabian Hueske 提交于
This closes #1331
-
由 Chiwan Park 提交于
- Remove unnecessary indentation of table - Fix wrong `strong` end tag - Simplify lambda expression in map operation This closes #1312
-
由 Sachin Goel 提交于
Bytes are now displayed in the following fashion: 1. For [0, 1000) units, display three significant digits. 2. For [1000,1024) units, display 2 decimal points for the next higher unit. For example, 1010 KB is displayed as 0.99 MB, 10 MB is displayed as 10.0 MB and 230 MB is displayed as such. This closes #1419
-
由 zentol 提交于
This closes #1420
-
由 Sachin Goel 提交于
This closes #1321
-
由 Stephan Ewen 提交于
This closes #1413
-
- 30 11月, 2015 4 次提交
-
-
由 Till Rohrmann 提交于
-
由 Till Rohrmann 提交于
Some TypeSerializer, WritableSerializer, ValueSerializer, and AvroSerializer, and comparators, WritableComparator and ValueComparator, use Kryo to copy records. In case where the Kryo serializer cannot copy the record, the copy method fails. This is however not necessary, because one can copy the element by serializing the record to a byte array and deserializing it from this array. This PR adds this behaviour to the respective classes. Adds KryoUtils tool with copy method to avoid code duplication This closes #1415. Adds comments to KryoUtils functions
-
由 Robert Metzger 提交于
This closes #1395
-
由 Gyula Fora 提交于
Closes #1402
-
- 29 11月, 2015 2 次提交
-
-
由 twalthr 提交于
Fix nullCheck enabled Fix test TableConfig introduced Improvements and bug fixing This closes #1322.
-
由 Robert Metzger 提交于
This closes #1410
-
- 28 11月, 2015 1 次提交
-
-
由 Robert Metzger 提交于
-
- 27 11月, 2015 7 次提交
-
-
由 Robert Metzger 提交于
This closes #1406
-
由 Maximilian Michels 提交于
The tab default also applied to Scala files which could lead to editing problems in IntelliJ.
-
由 twalthr 提交于
This closes #1393.
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Niels Basjes 提交于
This closes #1411
-
由 Stephan Ewen 提交于
This closes #1408
-
- 26 11月, 2015 6 次提交
-
-
由 Stephan Ewen 提交于
-
由 Robert Metzger 提交于
This closes #1407
-
由 fversaci 提交于
This closes #1405
-
由 jaoki 提交于
Currently the JavaDocs of writeAsText() state it simply generates a file, but this is not always true and it depends on the environment configuration. This commit improves the JavaDocs of writeAsText(). This closes #1392
-
由 zentol 提交于
This closes #1403
-
由 Maximilian Michels 提交于
- replace "implements" with "extends" where applicable
-
- 25 11月, 2015 3 次提交
-
-
由 Maximilian Michels 提交于
The default tab size on GitHub is 8 spaces. This change decreases the tab size to 4. I think this will make reviewing of code on GitHub much easier. This commit also introduces sensible defaults for editors which respect the ".editorconfig" file standard. This closes #1404.
-
由 Robert Metzger 提交于
This closes #1399
-
由 Robert Metzger 提交于
This closes #1400
-