mozetl.basic package¶

Submodules¶

mozetl.basic.transform module¶

class mozetl.basic.transform.DataFrameConfig(col_configs, ping_filter)[source]¶

Bases: object

get_paths()[source]¶

toStructType()[source]¶

mozetl.basic.transform.convert_pings(sqlContext, pings, data_frame_config)[source]¶: Performs basic data pipelining on raw telemetry pings

mozetl.basic.transform.convert_rdd(sqlContext, raw_data, data_frame_config)[source]¶

Performs basic data pipelining over an RDD, returning a DataFrame

raw_data must have a map method.

Module contents¶