Ниже приведен фрагмент кода, который я пытаюсь запустить, и столкнулся с проблемой недопустимого поля.
LIT__CALL_lt_CALL_segment_data = LOAD '/work/call/idrpnpc/lit/call/lt_call_segment' USING PigStorage('\u0001') AS (load_ts:chararray, source_location_id:chararray, destination_location_id:chararray, transportation_mode_cd:chararray, nifty_division_nbr:chararray, effective_dt:chararray, discontinue_dt:chararray, nifty_item_id:chararray, override_ind:chararray, planning_default_ind:chararray, order_duns_nbr:chararray, review_qty:int, contract_sopt_qty:int, calculated_sopt_qty:int, planning_sopt_qty:int, override_sopt_qty:int, transit_qty:int, put_away_qty:int, lead_time_variability_amt:chararray, customer_promise_factor_qty:int, customer_promise_day_qty:int, pick_up_day_nm:chararray,
arrival_day_nm:chararray, managed_vendor_ind:chararray, total_lead_time_qty:int, order_pattern_nm:chararray, order_interval_nm:chararray, order_policy_nm:chararray, source_location_level_cd:chararray, destination_location_level_cd:chararray, eligibility_status_cd:chararray, order_interval_qty:int, vendor_lead_time_qty:int, reporting_source_location_id:chararray, reporting_source_location_lead_time_qty:chararray, batchid:chararray);
LIT__CALL_lt_CALL_segment = foreach LIT__CALL_lt_CALL_segment_data generate
source_location_id,
destination_location_id,
effective_dt,
discontinue_dt,
nifty_item_id,
override_ind,
planning_default_ind,
total_lead_time_qty,
order_interval_qty,
destination_location_level_cd;
/*****************************filter LIT__CALL_lt_segment table***************************************************************/
LIT__CALL_lt_CALL_segment_warehouse_filter = FILTER LIT__CALL_lt_CALL_segment BY destination_location_level_cd == 'WAREHOUSE';
Получение ошибки ниже ошибочной проекции поля.
Неправильная проекция поля.Спроецированное поле [lit__call_lt_call_segment :: destination_location_level_cd] не существует в схеме: source_location_id: chararray, destination_location_id: chararray, эффективное_д.destination_location_level_cd: chararray.
Может кто-нибудь помочь мне в этом вопросе ??
Большое спасибо