[SPARK-25212][SQL] Support Filter in ConvertToLocalRelation#22205

Closed

bogdanrdc wants to merge 28 commits intoapache:masterfrom

bogdanrdc:local-relation-filter

Commits on Aug 23, 2018

Commits on Aug 24, 2018

Commits on Aug 28, 2018

[SPARK-25073][YARN] AM and Executor Memory validation message is not proper while submitting spark yarn application

sujith71955
authored and
bogdanrdc
committed
[SPARK-25214][SS] Fix the issue that Kafka v2 source may return duplicated records when `failOnDataLoss=false`

zsxwing
authored and
bogdanrdc
committed
[SPARK-25174][YARN] Limit the size of diagnostic message for am to unregister itself from rm

yaooqinn
authored and
bogdanrdc
committed
[SPARK-25234][SPARKR] avoid integer overflow in parallelize

mengxr
authored and
bogdanrdc
committed
Correct missing punctuation in the documentation

jaroslav chládek
authored and
bogdanrdc
committed
[MINOR] Fix Scala 2.12 build

dbtsai
authored and
bogdanrdc
committed
[SPARK-24688][EXAMPLES] Modify the comments about LabeledPoint

huangweizhe123
authored and
bogdanrdc
committed
[SPARK-25214][SS][FOLLOWUP] Fix the issue that Kafka v2 source may return duplicated records when `failOnDataLoss=false`

zsxwing
authored and
bogdanrdc
committed
[SPARK-23792][DOCS] Documentation improvements for datetime functions

abradbury
authored and
bogdanrdc
committed
[SPARK-23698][PYTHON][FOLLOWUP] Resolve undefiend names in setup.py

HyukjinKwon
authored and
bogdanrdc
committed
[SPARK-19355][SQL][FOLLOWUP] Remove the child.outputOrdering check in global limit

viirya
authored and
bogdanrdc
committed
[SPARK-24978][SQL] Add spark.sql.fast.hash.aggregate.row.max.capacity to configure the capacity of fast aggregation.

heary-cao
authored and
bogdanrdc
committed
[SPARK-25249][CORE][TEST] add a unit test for OpenHashMap

10110346
authored and
bogdanrdc
committed
[SPARK-24882][FOLLOWUP] Fix flaky synchronization in Kafka tests.

jose-torres
authored and
bogdanrdc
committed
[SPARK-24149][YARN][FOLLOW-UP] Only get the delegation tokens of the filesystem explicitly specified by the user

wangyum
authored and
bogdanrdc
committed
[SPARK-24090][K8S] Update running-on-kubernetes.md

liyinan926
authored and
bogdanrdc
committed
[SPARK-24721][SQL] Exclude Python UDFs filters in FileSourceStrategy

icexelloss
authored and
bogdanrdc
committed
[SPARK-25218][CORE] Fix potential resource leaks in TransportServer and SocketAuthHelper

zsxwing
authored and
bogdanrdc
committed
[SPARK-25005][SS] Support non-consecutive offsets for Kafka

zsxwing
authored and
bogdanrdc
committed
comment
bogdanrdc
committed
Merge remote-tracking branch 'upstream/master' into local-relation-filter
bogdanrdc
committed
Merge remote-tracking branch 'upstream/master' into local-relation-filter
bogdanrdc
committed
space
bogdanrdc
committed

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

[SPARK-25212][SQL] Support Filter in ConvertToLocalRelation#22205

[SPARK-25212][SQL] Support Filter in ConvertToLocalRelation#22205
bogdanrdc wants to merge 28 commits intoapache:masterfrom
bogdanrdc:local-relation-filter

Commits on Aug 23, 2018

optimization + test

debug benchmark + early batch

revert benchmark

Commits on Aug 24, 2018

Merge remote-tracking branch 'upstream/master' into local-relation-filter

test fix

Commits on Aug 28, 2018

[SPARK-25073][YARN] AM and Executor Memory validation message is not proper while submitting spark yarn application

[SPARK-25214][SS] Fix the issue that Kafka v2 source may return duplicated records when `failOnDataLoss=false`

[SPARK-25174][YARN] Limit the size of diagnostic message for am to unregister itself from rm

[SPARK-25234][SPARKR] avoid integer overflow in parallelize

Correct missing punctuation in the documentation

[MINOR] Fix Scala 2.12 build

[SPARK-24688][EXAMPLES] Modify the comments about LabeledPoint

[SPARK-25214][SS][FOLLOWUP] Fix the issue that Kafka v2 source may return duplicated records when `failOnDataLoss=false`

[SPARK-23792][DOCS] Documentation improvements for datetime functions

[SPARK-23698][PYTHON][FOLLOWUP] Resolve undefiend names in setup.py

[SPARK-19355][SQL][FOLLOWUP] Remove the child.outputOrdering check in global limit

[SPARK-24978][SQL] Add spark.sql.fast.hash.aggregate.row.max.capacity to configure the capacity of fast aggregation.

[SPARK-25249][CORE][TEST] add a unit test for OpenHashMap

[SPARK-24882][FOLLOWUP] Fix flaky synchronization in Kafka tests.

[SPARK-24149][YARN][FOLLOW-UP] Only get the delegation tokens of the filesystem explicitly specified by the user

[SPARK-24090][K8S] Update running-on-kubernetes.md

[SPARK-24721][SQL] Exclude Python UDFs filters in FileSourceStrategy

[SPARK-25218][CORE] Fix potential resource leaks in TransportServer and SocketAuthHelper

[SPARK-25005][SS] Support non-consecutive offsets for Kafka

comment

Merge remote-tracking branch 'upstream/master' into local-relation-filter

Merge remote-tracking branch 'upstream/master' into local-relation-filter

space