distrdf004_dask_lxbatch Namespace Reference

Functions
Client	create_connection ()
	Creates a connection to HTCondor cluster offered by the CERN batch service.
None	run_analysis (Client connection)
	Run a simple example with RDataFrame, using the previously created connection to the HTCondor cluster.

Variables
Client	connection = create_connection()
	end = time.time()
	start = time.time()

Function Documentation

create_connection()

Client distrdf004_dask_lxbatch.create_connection

(

)

Creates a connection to HTCondor cluster offered by the CERN batch service.

Returns a Dask client that RDataFrame will use to distribute computations.

Definition at line 34 of file distrdf004_dask_lxbatch.py.

run_analysis()

None distrdf004_dask_lxbatch.run_analysis

(

Client

connection

)

Run a simple example with RDataFrame, using the previously created connection to the HTCondor cluster.

Definition at line 88 of file distrdf004_dask_lxbatch.py.

Variable Documentation

connection

Client distrdf004_dask_lxbatch.connection = create_connection()

Definition at line 109 of file distrdf004_dask_lxbatch.py.

end

distrdf004_dask_lxbatch.end = time.time()

Definition at line 113 of file distrdf004_dask_lxbatch.py.

start

distrdf004_dask_lxbatch.start = time.time()

Definition at line 111 of file distrdf004_dask_lxbatch.py.