utilities/Utils.py [396:418]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    _table, _database, _tmp_uri = _get_offline_details(fg_name, s3_uri)
    
    # construct an Athena query
    
    fg_resp = describe_feature_group(fg_name)
    id_feature_name = fg_resp['RecordIdentifierFeatureName']
    time_feature_name = fg_resp['EventTimeFeatureName']

    feature_defs = fg_resp['FeatureDefinitions']
    feature_types = {}
    for fd in feature_defs:
        feature_types[fd['FeatureName']] = fd['FeatureType']
    id_feature_type = feature_types[id_feature_name]

    if feature_names is None:
        feature_name_string = '*'
    else:
        feature_name_string = ','.join(feature_names)
    
    if record_ids is None:
        where_clause = ''
    else:
        where_clause = ' WHERE ' + _make_where_clause(id_feature_name, id_feature_type, record_ids)
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



utilities/Utils.py [425:447]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    _table, _database, _tmp_uri = _get_offline_details(fg_name, s3_uri)

    # construct an Athena query
    
    fg_resp = describe_feature_group(fg_name)
    id_feature_name = fg_resp['RecordIdentifierFeatureName']
    time_feature_name = fg_resp['EventTimeFeatureName']

    feature_defs = fg_resp['FeatureDefinitions']
    feature_types = {}
    for fd in feature_defs:
        feature_types[fd['FeatureName']] = fd['FeatureType']
    id_feature_type = feature_types[id_feature_name]

    if feature_names is None:
        feature_name_string = '*'
    else:
        feature_name_string = ','.join(feature_names)
    
    if record_ids is None:
        where_clause = ''
    else:
        where_clause = ' WHERE ' + _make_where_clause(id_feature_name, id_feature_type, record_ids)
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -