Rev | Line | |
---|
[154] | 1 | import java.io.IOException; |
---|
| 2 | import java.util.*; |
---|
| 3 | |
---|
| 4 | import org.apache.pig.EvalFunc; |
---|
| 5 | import org.apache.pig.FuncSpec; |
---|
| 6 | import org.apache.pig.data.DataBag; |
---|
| 7 | import org.apache.pig.data.DefaultBagFactory; |
---|
| 8 | import org.apache.pig.data.DefaultTupleFactory; |
---|
| 9 | import org.apache.pig.data.Tuple; |
---|
| 10 | import org.apache.pig.impl.logicalLayer.schema.Schema; |
---|
| 11 | import org.apache.pig.data.DataType; |
---|
| 12 | import org.apache.pig.impl.logicalLayer.FrontendException; |
---|
| 13 | |
---|
| 14 | public class Concat extends EvalFunc<DataBag> { |
---|
| 15 | |
---|
| 16 | @Override |
---|
| 17 | public DataBag exec(Tuple input) throws IOException { |
---|
| 18 | |
---|
| 19 | if (input == null || input.size() == 0) |
---|
| 20 | return null; |
---|
| 21 | try{ |
---|
| 22 | |
---|
| 23 | if(input.get(0) != null && input.get(1) != null) { |
---|
| 24 | String token1 = input.get(0).toString(); |
---|
| 25 | StringTokenizer st1 = new StringTokenizer(token1); |
---|
| 26 | String nodeId = st1.nextToken(); |
---|
| 27 | |
---|
| 28 | String token2 = input.get(1).toString(); |
---|
| 29 | StringTokenizer st2 = new StringTokenizer(token2); |
---|
| 30 | String platformId = st2.nextToken(); |
---|
| 31 | |
---|
| 32 | |
---|
| 33 | DataBag output = DefaultBagFactory.getInstance().newDefaultBag(); |
---|
| 34 | Tuple t = DefaultTupleFactory.getInstance().newTuple(1); |
---|
| 35 | String label = nodeId + ";" + platformId; |
---|
| 36 | t.set(0, label); |
---|
| 37 | |
---|
| 38 | output.add(t); |
---|
| 39 | return output; |
---|
| 40 | } |
---|
| 41 | |
---|
| 42 | return null; |
---|
| 43 | |
---|
| 44 | }catch(Exception e){ |
---|
| 45 | System.err.println("RealLabelsr: failed to process input; error - " + e.getMessage()); |
---|
| 46 | e.printStackTrace(); |
---|
| 47 | return null; |
---|
| 48 | } |
---|
| 49 | |
---|
| 50 | |
---|
| 51 | } |
---|
| 52 | } |
---|
Note: See
TracBrowser
for help on using the repository browser.