aboutsummaryrefslogtreecommitdiff
path: root/extras/kinesis-asl
Commit message (Expand)AuthorAgeFilesLines
* [SPARK-13595][BUILD] Move docker, extras modules into externalSean Owen2016-03-0920-3652/+0
* [SPARK-13702][CORE][SQL][MLLIB] Use diamond operator for generic instance cre...Dongjoon Hyun2016-03-091-1/+1
* [SPARK-13692][CORE][SQL] Fix trivial Coverity/Checkstyle defectsDongjoon Hyun2016-03-091-2/+0
* [SPARK-13655] Improve isolation between tests in KinesisBackedBlockRDDSuiteJosh Rosen2016-03-071-13/+17
* [SPARK-13186][STREAMING] migrate away from SynchronizedMapHuaxin Gao2016-02-221-17/+21
* [SPARK-6363][BUILD] Make Scala 2.11 the default Scala versionJosh Rosen2016-01-301-2/+2
* [SPARK-3369][CORE][STREAMING] Java mapPartitions Iterator->Iterable is incons...Sean Owen2016-01-261-3/+6
* [SPARK-12960] [PYTHON] Some examples are missing support for python2Mark Grover2016-01-211-0/+2
* [SPARK-12692][BUILD][HOT-FIX] Fix the scala style of KinesisBackedBlockRDDSui...Yin Huai2016-01-131-2/+2
* [SPARK-3873][BUILD] Enable import ordering error checking.Marcelo Vanzin2016-01-108-10/+10
* [SPARK-12618][CORE][STREAMING][SQL] Clean up build warnings: 2.0.0 editionSean Owen2016-01-081-4/+4
* [SPARK-12453][STREAMING] Remove explicit dependency on aws-java-sdkBrianLondon2016-01-052-5/+1
* [SPARK-12525] Fix fatal compiler warnings in Kinesis ASL due to @transient an...Josh Rosen2015-12-282-8/+8
* Bump master version to 2.0.0-SNAPSHOT.Reynold Xin2015-12-191-1/+1
* [SPARK-11193] Use Java ConcurrentHashMap instead of SynchronizedMap trait in ...Jean-Baptiste Onofré2015-12-121-8/+8
* [SPARK-12084][CORE] Fix codes that uses ByteBuffer.array incorrectlyShixiong Zhu2015-12-041-1/+2
* [SPARK-12058][STREAMING][KINESIS][TESTS] fix Kinesis python testsBurak Yavuz2015-12-044-49/+115
* [SPARK-12046][DOC] Fixes various ScalaDoc/JavaDoc issuesCheng Lian2015-12-012-17/+19
* [SPARK-11198][STREAMING][KINESIS] Support de-aggregation of records during re...Burak Yavuz2015-11-097-25/+74
* [SPARK-11359][STREAMING][KINESIS] Checkpoint to DynamoDB even when new data d...Burak Yavuz2015-11-096-183/+349
* [SPARK-10891][STREAMING][KINESIS] Add MessageHandler to KinesisUtils.createSt...Burak Yavuz2015-10-259-75/+337
* [SPARK-10300] [BUILD] [TESTS] Add support for test tags in run-tests.py.Marcelo Vanzin2015-10-071-3/+2
* Revert "[SPARK-10300] [BUILD] [TESTS] Add support for test tags in run-tests....Marcelo Vanzin2015-09-151-0/+5
* [SPARK-10300] [BUILD] [TESTS] Add support for test tags in run-tests.py.Marcelo Vanzin2015-09-151-5/+0
* Update version to 1.6.0-SNAPSHOT.Reynold Xin2015-09-151-1/+1
* [SPARK-9613] [CORE] Ban use of JavaConversions and migrate all existing uses ...Sean Owen2015-08-254-11/+12
* [SPARK-9791] [PACKAGE] Change private class to private class to prevent unnec...Tathagata Das2015-08-241-1/+1
* [SPARK-9727] [STREAMING] [BUILD] Updated streaming kinesis SBT project name t...Tathagata Das2015-08-111-1/+1
* [SPARK-9556] [SPARK-9619] [SPARK-9624] [STREAMING] Make BlockGenerator more r...Tathagata Das2015-08-061-1/+1
* [SPARK-9217] [STREAMING] Make the kinesis receiver reliable by recording sequ...Tathagata Das2015-08-0510-165/+566
* [SPARK-8564] [STREAMING] Add the Python API for Kinesiszsxwing2015-07-313-19/+159
* [STREAMING] [TEST] [HOTFIX] Fixed Kinesis test to not throw weird errors when...Tathagata Das2015-07-302-15/+16
* [SPARK-9335] [STREAMING] [TESTS] Make sure the test stream is deleted in Kine...zsxwing2015-07-272-4/+7
* [HOTFIX] - Disable Kinesis tests due to rate limitsPatrick Wendell2015-07-241-2/+2
* [SPARK-9216] [STREAMING] Define KinesisBackedBlockRDDsTathagata Das2015-07-235-5/+545
* [SPARK-9030] [STREAMING] [HOTFIX] Make sure that no attempts to create Kinesi...Tathagata Das2015-07-191-31/+26
* [SPARK-9030] [STREAMING] Add Kinesis.createStream unit tests that actual send...Tathagata Das2015-07-174-17/+354
* [SPARK-7977] [BUILD] Disallowing printlnJonathan Alter2015-07-101-0/+2
* Revert "[SPARK-8781] Fix variables in published pom.xml are not resolved"Andrew Or2015-07-062-12/+15
* [SPARK-8781] Fix variables in published pom.xml are not resolvedAndrew Or2015-07-022-15/+12
* [SPARK-8683] [BUILD] Depend on mockito-core instead of mockito-allJosh Rosen2015-06-271-1/+1
* [BUILD] Fix Maven build for KinesisAndrew Or2015-06-031-0/+7
* [SPARK-7801] [BUILD] Updating versions to SPARK 1.5.0Patrick Wendell2015-06-031-1/+1
* [SPARK-3850] Trim trailing spaces for examples/streaming/yarn.Reynold Xin2015-05-314-28/+28
* [SPARK-7929] Turn whitespace checker on for more token types.Reynold Xin2015-05-282-3/+3
* [SPARK-7838] [STREAMING] Set scope for kinesis streamTathagata Das2015-05-221-3/+6
* [SPARK-7788] Made KinesisReceiver.onStart() non-blockingTathagata Das2015-05-221-5/+25
* [SPARK-7722] [STREAMING] Added Kinesis to style checkerTathagata Das2015-05-211-1/+1
* [SPARK-7787] [STREAMING] Fix serialization issue of SerializableAWSCredentialsTathagata Das2015-05-212-18/+17
* [HOTFIX] Fixing style failures in Kinesis sourcePatrick Wendell2015-05-192-4/+6