@@ -783,42 +783,18 @@ def read(self, path, offset=None, length=None, headers=None):
783783 _data ['length' ] = length
784784 return self .client .perform_query ('GET' , '/dbfs/read' , data = _data , headers = headers )
785785
786- def read_test (self , path , offset = None , length = None , headers = None ):
787- _data = {}
788- if path is not None :
789- _data ['path' ] = path
790- if offset is not None :
791- _data ['offset' ] = offset
792- if length is not None :
793- _data ['length' ] = length
794- return self .client .perform_query ('GET' , '/dbfs-testing/read' , data = _data , headers = headers )
795-
796786 def get_status (self , path , headers = None ):
797787 _data = {}
798788 if path is not None :
799789 _data ['path' ] = path
800790 return self .client .perform_query ('GET' , '/dbfs/get-status' , data = _data , headers = headers )
801791
802- def get_status_test (self , path , headers = None ):
803- _data = {}
804- if path is not None :
805- _data ['path' ] = path
806- return self .client .perform_query (
807- 'GET' , '/dbfs-testing/get-status' , data = _data , headers = headers
808- )
809-
810792 def list (self , path , headers = None ):
811793 _data = {}
812794 if path is not None :
813795 _data ['path' ] = path
814796 return self .client .perform_query ('GET' , '/dbfs/list' , data = _data , headers = headers )
815797
816- def list_test (self , path , headers = None ):
817- _data = {}
818- if path is not None :
819- _data ['path' ] = path
820- return self .client .perform_query ('GET' , '/dbfs-testing/list' , data = _data , headers = headers )
821-
822798 def put (self , path , contents = None , overwrite = None , headers = None , src_path = None ):
823799 _data = {}
824800 _files = None
@@ -836,37 +812,12 @@ def put(self, path, contents=None, overwrite=None, headers=None, src_path=None):
836812 'POST' , '/dbfs/put' , data = _data , headers = headers , files = _files
837813 )
838814
839- def put_test (self , path , contents = None , overwrite = None , headers = None , src_path = None ):
840- _data = {}
841- _files = None
842- if path is not None :
843- _data ['path' ] = path
844- if contents is not None :
845- _data ['contents' ] = contents
846- if overwrite is not None :
847- _data ['overwrite' ] = overwrite
848- if src_path is not None :
849- headers = {'Content-Type' : None }
850- filename = os .path .basename (src_path )
851- _files = {'file' : (filename , open (src_path , 'rb' ), 'multipart/form-data' )}
852- return self .client .perform_query (
853- 'POST' , '/dbfs-testing/put' , data = _data , headers = headers , files = _files
854- )
855-
856815 def mkdirs (self , path , headers = None ):
857816 _data = {}
858817 if path is not None :
859818 _data ['path' ] = path
860819 return self .client .perform_query ('POST' , '/dbfs/mkdirs' , data = _data , headers = headers )
861820
862- def mkdirs_test (self , path , headers = None ):
863- _data = {}
864- if path is not None :
865- _data ['path' ] = path
866- return self .client .perform_query (
867- 'POST' , '/dbfs-testing/mkdirs' , data = _data , headers = headers
868- )
869-
870821 def move (self , source_path , destination_path , headers = None ):
871822 _data = {}
872823 if source_path is not None :
@@ -875,14 +826,6 @@ def move(self, source_path, destination_path, headers=None):
875826 _data ['destination_path' ] = destination_path
876827 return self .client .perform_query ('POST' , '/dbfs/move' , data = _data , headers = headers )
877828
878- def move_test (self , source_path , destination_path , headers = None ):
879- _data = {}
880- if source_path is not None :
881- _data ['source_path' ] = source_path
882- if destination_path is not None :
883- _data ['destination_path' ] = destination_path
884- return self .client .perform_query ('POST' , '/dbfs-testing/move' , data = _data , headers = headers )
885-
886829 def delete (self , path , recursive = None , headers = None ):
887830 _data = {}
888831 if path is not None :
@@ -891,16 +834,6 @@ def delete(self, path, recursive=None, headers=None):
891834 _data ['recursive' ] = recursive
892835 return self .client .perform_query ('POST' , '/dbfs/delete' , data = _data , headers = headers )
893836
894- def delete_test (self , path , recursive = None , headers = None ):
895- _data = {}
896- if path is not None :
897- _data ['path' ] = path
898- if recursive is not None :
899- _data ['recursive' ] = recursive
900- return self .client .perform_query (
901- 'POST' , '/dbfs-testing/delete' , data = _data , headers = headers
902- )
903-
904837 def create (self , path , overwrite = None , headers = None ):
905838 _data = {}
906839 if path is not None :
@@ -909,16 +842,6 @@ def create(self, path, overwrite=None, headers=None):
909842 _data ['overwrite' ] = overwrite
910843 return self .client .perform_query ('POST' , '/dbfs/create' , data = _data , headers = headers )
911844
912- def create_test (self , path , overwrite = None , headers = None ):
913- _data = {}
914- if path is not None :
915- _data ['path' ] = path
916- if overwrite is not None :
917- _data ['overwrite' ] = overwrite
918- return self .client .perform_query (
919- 'POST' , '/dbfs-testing/create' , data = _data , headers = headers
920- )
921-
922845 def add_block (self , handle , data , headers = None ):
923846 _data = {}
924847 if handle is not None :
@@ -927,28 +850,12 @@ def add_block(self, handle, data, headers=None):
927850 _data ['data' ] = data
928851 return self .client .perform_query ('POST' , '/dbfs/add-block' , data = _data , headers = headers )
929852
930- def add_block_test (self , handle , data , headers = None ):
931- _data = {}
932- if handle is not None :
933- _data ['handle' ] = handle
934- if data is not None :
935- _data ['data' ] = data
936- return self .client .perform_query (
937- 'POST' , '/dbfs-testing/add-block' , data = _data , headers = headers
938- )
939-
940853 def close (self , handle , headers = None ):
941854 _data = {}
942855 if handle is not None :
943856 _data ['handle' ] = handle
944857 return self .client .perform_query ('POST' , '/dbfs/close' , data = _data , headers = headers )
945858
946- def close_test (self , handle , headers = None ):
947- _data = {}
948- if handle is not None :
949- _data ['handle' ] = handle
950- return self .client .perform_query ('POST' , '/dbfs-testing/close' , data = _data , headers = headers )
951-
952859
953860class WorkspaceService (object ):
954861 def __init__ (self , client ):
0 commit comments