Skip to content

Commit

Permalink
fix mistakes during rebase
Browse files Browse the repository at this point in the history
  • Loading branch information
kiszk committed Apr 19, 2018
1 parent 2fbb1e8 commit 06fb27e
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
3 changes: 1 addition & 2 deletions python/pyspark/sql/functions.py
Original file line number Diff line number Diff line change
Expand Up @@ -1845,7 +1845,6 @@ def array_contains(col, value):
return Column(sc._jvm.functions.array_contains(_to_java_column(col), value))


@ignore_unicode_prefix
@since(2.4)
def array_position(col, value):
"""
Expand All @@ -1866,7 +1865,7 @@ def array_position(col, value):
@since(2.4)
def element_at(col, extraction):
"""
Collection function: returns element of array at given index in extraction if col is array.
Collection function: Returns element of array at given index in extraction if col is array.
returns value for the given key in extraction if col is map.
:param col: name of column containing array or map
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -566,6 +566,7 @@ class DataFrameFunctionsSuite extends QueryTest with SharedSQLContext {
checkAnswer(
df.selectExpr("array_position(array(1, null), array(1, null)[0])"),
Seq(Row(1L), Row(1L))
)
}

test("element_at function") {
Expand Down

0 comments on commit 06fb27e

Please sign in to comment.