in parquet_flask/io_logic/query_v4.py [0:0]
def __init__(self, props=QueryProps()):
self.__props = props
config = Config()
self.__app_name = config.get_spark_app_name()
self.__master_spark = config.get_value(Config.master_spark_url)
self.__parquet_name = config.get_value(Config.parquet_file_name)
self.__es_config = {
'es_url': config.get_value(Config.es_url),
'es_index': CDMSConstants.es_index_parquet_stats,
'es_port': int(config.get_value(Config.es_port, '443')),
}
self.__parquet_name = self.__parquet_name if not self.__parquet_name.endswith('/') else self.__parquet_name[:-1]
self.__missing_depth_value = CDMSConstants.missing_depth_value
self.__conditions = []
self.__sorting_columns = [CDMSConstants.time_col, CDMSConstants.platform_code_col, CDMSConstants.depth_col, CDMSConstants.lat_col, CDMSConstants.lon_col]
self.__set_missing_depth_val()