Skip to content

Commit 63de8f8

Browse files
committed
fix typo
1 parent c79ca67 commit 63de8f8

File tree

1 file changed

+6
-6
lines changed

1 file changed

+6
-6
lines changed

python/pyspark/sql.py

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -525,7 +525,7 @@ def _dropSchema(rows, schema):
525525
yield converter(i)
526526

527527

528-
_BRAKETS = {'(': ')', '[': ']', '{': '}'}
528+
_BRACKETS = {'(': ')', '[': ']', '{': '}'}
529529

530530

531531
def _split_schema_abstract(s):
@@ -552,10 +552,10 @@ def _split_schema_abstract(s):
552552
w = ''
553553
else:
554554
w += c
555-
if c in _BRAKETS:
555+
if c in _BRACKETS:
556556
brackets.append(c)
557-
elif c in _BRAKETS.values():
558-
if not brackets or c != _BRAKETS[brackets.pop()]:
557+
elif c in _BRACKETS.values():
558+
if not brackets or c != _BRACKETS[brackets.pop()]:
559559
raise ValueError("unexpected " + c)
560560

561561
if brackets:
@@ -578,8 +578,8 @@ def _parse_field_abstract(s):
578578
>>> _parse_field_abstract("a{[]}")
579579
StructField(a,MapType(None,ArrayType(None,true),true),true)
580580
"""
581-
if set(_BRAKETS.keys()) & set(s):
582-
idx = min((s.index(c) for c in _BRAKETS if c in s))
581+
if set(_BRACKETS.keys()) & set(s):
582+
idx = min((s.index(c) for c in _BRACKETS if c in s))
583583
name = s[:idx]
584584
return StructField(name, _parse_schema_abstract(s[idx:]), True)
585585
else:

0 commit comments

Comments
 (0)