pig-udf

0La chaleur

1Répondre

comment puis-je écrire UDF pour convertir la deuxième colonne en majuscule

package com.hadoopexpert; import java.io.IOException; import org.apache.pig.EvalFunc; import org.apache.pig.data.Tuple; public class upper extends EvalFunc<String> { pub

1La chaleur

1Répondre

Efficacité de coef uf contre fucntions intégré en cascade

Je suis nouveau à PIG scripting, j'avais une exigence où j'ai eu besoin d'effectuer Ladder If Else pour jusqu'à 10 conditions, De quelle connaissance j'ai nous avons seulement l'opérateur ternaire, do

1La chaleur

1Répondre

Lancer UDF de porc NullPointerException lors de la génération d'un nouveau tuple

J'ai une UDF de porc qui ingère des données et tente ensuite de transformer ces données de manière minimale. my_data = LOAD 'path/to/data' USING SomeCustomLoader(); my_other_data = FOREACH my_data GE

3La chaleur

2Répondre

Comment créer UDF dans cochon pour les colonnes de catégorisation par rapport à un autre classé

Je veux catégoriser une colonne par rapport à l'autre colonne en utilisant UDF dans le cochon. données i ont Id,name,age 1,jhon,31 2,adi,15 3,sam,25 4,lina,28 Sortie prévue 1,jhon,31,30-35 2,ad

0La chaleur

1Répondre

Comment fonctionne PigStorage?

Je suis nouveau à Apache Pig et je veux savoir quelques détails de traitement sur la façon dont il stocke des enregistrements de données à FS. 1.Pour chaque Tuple, où PigStorage les transforme-t-il en

-1La chaleur

1Répondre

Impossible d'importer outputSchema à partir de pigutil en python

Cela peut être une question assez basique, je suis nouveau dans la zone porc et python. J'essaye d'importer outputSchema de pigutil. Le outputSchema est utilisé comme suit dans l'UDF python: - @output

-1La chaleur

1Répondre

fonction utilisateur dans Pig Latin

J'utilise Java pour créer une fonction définie par l'utilisateur UDF pour Pig Latin dans un environnement Hadoop. Je veux créer plusieurs fichiers de sortie. J'ai essayé de créer un programme Java pou

0La chaleur

1Répondre

Pig générer une colonne de changement de clé - comparer l'enregistrement précédent avec l'enregistrement en cours, mais la colonne différente

Mes données d'entrée seront dans le format ci-dessous. col1 col2 col3 effective date expiry date 1 Q1 A1 Value1 01/01 01/02 2 Q1 A1 Value1 01/02 01/03 3 Q1 A1 Value1 01/03 01/05 4 Q1 A1

0La chaleur

1Répondre

Comment Pig instancie-t-il des objets UDF

Quelqu'un peut-il me dire comment Pig instancie des objets UDF? J'ai utilisé Pig pour construire un pipeline pour traiter certaines données. J'ai déployé le pipeline dans le cluster multi-noeud Hadoop