8000 Commits · prabeesh/spark · GitHub

More Web Proxy on the site http://driver.im/

Commits

Commits on May 31, 2016

[SPARK-15517][SQL][STREAMING] Add support for complete output mode in Structure Streaming

tdas
authored and
marmbrus
committed

Commits on May 24, 2016

[SPARK-15458][SQL][STREAMING] Disable schema inference for streaming datasets on file streams
tdas
committed

Commits on May 22, 2016

[SPARK-15428][SQL] Disable multiple streaming aggregations
tdas
committed

Commits on May 11, 2016

[SPARK-15248][SQL] Make MetastoreFileCatalog consider directories from partition specs of a partitioned metastore table

tdas
authored and
yhuai
committed

Commits on May 10, 2016

[SPARK-14837][SQL][STREAMING] Added support in file stream source for reading new files added to subdirs

tdas
authored and
yhuai
committed

Commits on May 6, 2016

[SPARK-14997][SQL] Fixed FileCatalog to return correct set of files when there is no partitioning scheme in the given paths

tdas
authored and
yhuai
committed

Commits on May 5, 2016

[SPARK-15131][SQL] Shutdown StateStore management thread when SparkContext has been shutdown

tdas
authored and
zsxwing
committed

Commits on May 4, 2016

[SPARK-15103][SQL] Refactored FileCatalog class to allow StreamFileCatalog to infer partitioning
tdas
committed

Commits on May 3, 2016

[SPARK-14716][SQL] Added support for partitioning in FileStreamSink
tdas
committed

Commits on Apr 28, 2016

[SPARK-14970][SQL] Prevent DataSource from enumerates all files in a directory if there is user specified schema

tdas
authored and
marmbrus
committed

Commits on Apr 24, 2016

[SPARK-14833][SQL][STREAMING][TEST] Refactor StreamTests to test for source fault-tolerance correctly.

tdas
authored and
zsxwing
committed

Commits on Apr 23, 2016

[SPARK-14832][SQL][STREAMING] Refactor DataSource to ensure schema is inferred only once when creating a file stream

tdas
authored and
zsxwing
committed

Commits on Apr 20, 2016

[SPARK-14741][SQL] Fixed error in reading json file stream inside a partitioned directory

tdas
authored and
marmbrus
committed

Commits on Apr 18, 2016

[SPARK-14473][SQL] Define analysis rules to catch operations not supported in streaming

tdas
authored and
zsxwing
committed

Commits on Apr 7, 2016

[SQL][TESTS] Fix for flaky test in ContinuousQueryManagerSuite

tdas
authored and
zsxwing
committed

Commits on Apr 6, 2016

[SPARK-12133][STREAMING] Streaming dynamic allocation

tdas
authored and
Andrew Or
committed

Commits on Mar 26, 2016

[SPARK-14109][SQL] Fix HDFSMetadataLog to fallback from FileContext to FileSystem API
tdas
committed

Commits on Mar 25, 2016

[SQL][HOTFIX] Fix flakiness in StateStoreRDDSuite

tdas
authored and
zsxwing
committed

Commits on Mar 23, 2016

[SPARK-13809][SQL] State store for streaming aggregations
tdas
committed

Commits on Mar 10, 2016

[SQL][TEST] Increased timeouts to reduce flakiness in ContinuousQueryManagerSuite

tdas
authored and
yhuai
committed

Commits on Feb 11, 2016

[STREAMING][TEST] Fix flaky streaming.FailureSuite

tdas
authored and
zsxwing
committed
[SPARK-13146][SQL] Management API for continuous queries

tdas
authored and
zsxwing
committed

Commits on Dec 10, 2015

[SPARK-12244][SPARK-12245][STREAMING] Rename trackStateByKey to mapWithState and change tracking function signature

tdas
authored and
zsxwing
committed

Commits on Dec 7, 2015

[SPARK-11932][STREAMING] Partition previous TrackStateRDD if partitioner not present
tdas
committed

Commits on Dec 4, 2015

[SPARK-12122][STREAMING] Prevent batches from being submitted twice after recovering StreamingContext from checkpoint
tdas
committed

Commits on Dec 3, 2015

[FLAKY-TEST-FIX][STREAMING][TEST] Make sure StreamingContexts are shutdown after test
tdas
committed

Commits on Dec 2, 2015

[SPARK-12087][STREAMING] Create new JobConf for every batch in saveAsHadoopFiles

tdas
authored and
zsxwing
committed

Commits on Dec 1, 2015

[SPARK-12004] Preserve the RDD partitioner through RDD checkpointing

tdas
authored and
Andrew Or
committed

Commits on Nov 25, 2015

[SPARK-11979][STREAMING] Empty TrackStateRDD cannot be checkpointed and recovered from checkpoint file

tdas
authored and
zsxwing
committed

Commits on Nov 20, 2015

[SPARK-11845][STREAMING][TEST] Added unit test to verify TrackStateRDD is correctly checkpointed

tdas
authored and
Andrew Or
committed

Commits on Nov 19, 2015

[SPARK-11814][STREAMING] Add better default checkpoint duration
tdas
committed

Commits on Nov 13, 2015

[SPARK-11681][STREAMING] Correctly update state timestamp even when state is not updated
tdas
committed

Commits on Nov 11, 2015

Commits on Sep 23, 2015

[SPARK-10652] [SPARK-10742] [STREAMING] Set meaningful job descriptions for all streaming jobs
tdas
committed

0