@@ -226,8 +226,8 @@ def _indicator_pre_merge(self, left, right):
226
226
227
227
for i in ['_left_indicator' , '_right_indicator' ]:
228
228
if i in columns :
229
- raise ValueError (
230
- "Cannot use `indicator=True` option when data contains a column named {}" .format (i ))
229
+ raise ValueError ("Cannot use `indicator=True` option when "
230
+ " data contains a column named {}" .format (i ))
231
231
if self .indicator_name in columns :
232
232
raise ValueError (
233
233
"Cannot use name of an existing column for indicator column" )
@@ -248,14 +248,15 @@ def _indicator_post_merge(self, result):
248
248
result ['_left_indicator' ] = result ['_left_indicator' ].fillna (0 )
249
249
result ['_right_indicator' ] = result ['_right_indicator' ].fillna (0 )
250
250
251
- result [self .indicator_name ] = Categorical (
252
- (result ['_left_indicator' ] + result ['_right_indicator' ]), categories = [1 , 2 , 3 ])
253
- result [self .indicator_name ] = result [self .indicator_name ].cat .rename_categories (
254
- ['left_only' , 'right_only' , 'both' ])
255
-
256
- result = result .drop (
257
- labels = ['_left_indicator' , '_right_indicator' ], axis = 1 )
251
+ result [self .indicator_name ] = Categorical ((result ['_left_indicator' ] +
252
+ result ['_right_indicator' ]),
253
+ categories = [1 , 2 , 3 ])
254
+ result [self .indicator_name ] = (
255
+ result [self .indicator_name ]
256
+ .cat .rename_categories (['left_only' , 'right_only' , 'both' ]))
258
257
258
+ result = result .drop (labels = ['_left_indicator' , '_right_indicator' ],
259
+ axis = 1 )
259
260
return result
260
261
261
262
def _maybe_add_join_keys (self , result , left_indexer , right_indexer ):
@@ -280,8 +281,9 @@ def _maybe_add_join_keys(self, result, left_indexer, right_indexer):
280
281
continue
281
282
282
283
right_na_indexer = right_indexer .take (na_indexer )
283
- result .iloc [na_indexer , key_indexer ] = com .take_1d (self .right_join_keys [i ],
284
- right_na_indexer )
284
+ result .iloc [na_indexer , key_indexer ] = (
285
+ com .take_1d (self .right_join_keys [i ],
286
+ right_na_indexer ))
285
287
elif name in self .right :
286
288
if len (self .right ) == 0 :
287
289
continue
@@ -291,8 +293,9 @@ def _maybe_add_join_keys(self, result, left_indexer, right_indexer):
291
293
continue
292
294
293
295
left_na_indexer = left_indexer .take (na_indexer )
294
- result .iloc [na_indexer , key_indexer ] = com .take_1d (self .left_join_keys [i ],
295
- left_na_indexer )
296
+ result .iloc [na_indexer , key_indexer ] = (
297
+ com .take_1d (self .left_join_keys [i ],
298
+ left_na_indexer ))
296
299
elif left_indexer is not None \
297
300
and isinstance (self .left_join_keys [i ], np .ndarray ):
298
301
@@ -761,12 +764,13 @@ def _get_join_keys(llab, rlab, shape, sort):
761
764
762
765
return _get_join_keys (llab , rlab , shape , sort )
763
766
764
- #- ---------------------------------------------------------------------
767
+ # ---------------------------------------------------------------------
765
768
# Concatenate DataFrame objects
766
769
767
770
768
771
def concat (objs , axis = 0 , join = 'outer' , join_axes = None , ignore_index = False ,
769
- keys = None , levels = None , names = None , verify_integrity = False , copy = True ):
772
+ keys = None , levels = None , names = None , verify_integrity = False ,
773
+ copy = True ):
770
774
"""
771
775
Concatenate pandas objects along a particular axis with optional set logic
772
776
along the other axes. Can also add a layer of hierarchical indexing on the
@@ -897,7 +901,8 @@ def __init__(self, objs, axis=0, join='outer', join_axes=None,
897
901
# if we have not multi-index possibiltes
898
902
df = DataFrame ([obj .shape for obj in objs ]).sum (1 )
899
903
non_empties = df [df != 0 ]
900
- if len (non_empties ) and (keys is None and names is None and levels is None and join_axes is None ):
904
+ if (len (non_empties ) and (keys is None and names is None and
905
+ levels is None and join_axes is None )):
901
906
objs = [objs [i ] for i in non_empties .index ]
902
907
sample = objs [0 ]
903
908
@@ -967,19 +972,23 @@ def get_result(self):
967
972
if self .axis == 0 :
968
973
new_data = com ._concat_compat ([x ._values for x in self .objs ])
969
974
name = com ._consensus_name_attr (self .objs )
970
- return Series (new_data , index = self .new_axes [0 ], name = name ).__finalize__ (self , method = 'concat' )
975
+ return (Series (new_data , index = self .new_axes [0 ], name = name )
976
+ .__finalize__ (self , method = 'concat' ))
971
977
972
978
# combine as columns in a frame
973
979
else :
974
980
data = dict (zip (range (len (self .objs )), self .objs ))
975
981
index , columns = self .new_axes
976
982
tmpdf = DataFrame (data , index = index )
977
- # checks if the column variable already stores valid column names (because set via the 'key' argument
978
- # in the 'concat' function call. If that's not the case, use
979
- # the series names as column names
980
- if columns .equals (Index (np .arange (len (self .objs )))) and not self .ignore_index :
981
- columns = np .array (
982
- [data [i ].name for i in range (len (data ))], dtype = 'object' )
983
+ # checks if the column variable already stores valid column
984
+ # names (because set via the 'key' argument in the 'concat'
985
+ # function call. If that's not the case, use the series names
986
+ # as column names
987
+ if (columns .equals (Index (np .arange (len (self .objs )))) and
988
+ not self .ignore_index ):
989
+ columns = np .array ([data [i ].name
990
+ for i in range (len (data ))],
991
+ dtype = 'object' )
983
992
indexer = isnull (columns )
984
993
if indexer .any ():
985
994
columns [indexer ] = np .arange (len (indexer [indexer ]))
@@ -1004,11 +1013,13 @@ def get_result(self):
1004
1013
mgrs_indexers .append ((obj ._data , indexers ))
1005
1014
1006
1015
new_data = concatenate_block_managers (
1007
- mgrs_indexers , self .new_axes , concat_axis = self .axis , copy = self .copy )
1016
+ mgrs_indexers , self .new_axes ,
1017
+ concat_axis = self .axis , copy = self .copy )
1008
1018
if not self .copy :
1009
1019
new_data ._consolidate_inplace ()
1010
1020
1011
- return self .objs [0 ]._from_axes (new_data , self .new_axes ).__finalize__ (self , method = 'concat' )
1021
+ return (self .objs [0 ]._from_axes (new_data , self .new_axes )
1022
+ .__finalize__ (self , method = 'concat' ))
1012
1023
1013
1024
def _get_result_dim (self ):
1014
1025
if self ._is_series and self .axis == 1 :
@@ -1214,7 +1225,8 @@ def _make_concat_multiindex(indexes, keys, levels=None, names=None):
1214
1225
1215
1226
1216
1227
def _should_fill (lname , rname ):
1217
- if not isinstance (lname , compat .string_types ) or not isinstance (rname , compat .string_types ):
1228
+ if (not isinstance (lname , compat .string_types ) or
1229
+ not isinstance (rname , compat .string_types )):
1218
1230
return True
1219
1231
return lname == rname
1220
1232
0 commit comments