Revision 57521
Added by Antonis Lempesis over 4 years ago
StatsMapper.java | ||
---|---|---|
128 | 128 |
String serialized = serializer.serialize(oaf); |
129 | 129 |
if (serialized != null) { |
130 | 130 |
try { |
131 |
// Text TextKeyOut; |
|
132 |
// |
|
133 |
// switch (oaf.getEntity().getType()) { |
|
134 |
// case project: |
|
135 |
// case datasource: |
|
136 |
// case organization: |
|
137 |
// TextKeyOut = new Text(oaf.getEntity().getType().toString() + "," + serializer.getId(oaf)); |
|
138 |
// break; |
|
139 |
// case result: |
|
140 |
// default: |
|
141 |
// TextKeyOut = new Text(oaf.getEntity().getType().toString() + "," + id); |
|
142 |
// break; |
|
143 |
// } |
|
131 |
Text TextKeyOut; |
|
144 | 132 |
|
145 |
Text TextKeyOut = new Text(oaf.getEntity().getType().toString() + "," + serializer.getId(oaf)); |
|
133 |
switch (oaf.getEntity().getType()) { |
|
134 |
case project: |
|
135 |
case datasource: |
|
136 |
case organization: |
|
137 |
TextKeyOut = new Text(oaf.getEntity().getType().toString() + "," + serializer.getId(oaf)); |
|
138 |
break; |
|
139 |
case result: |
|
140 |
default: |
|
141 |
TextKeyOut = new Text(oaf.getEntity().getType().toString() + "," + id); |
|
142 |
break; |
|
143 |
} |
|
146 | 144 |
|
147 | 145 |
context.write(TextKeyOut, new ImmutableBytesWritable(serialized.getBytes())); |
148 | 146 |
context.getCounter(STATS_COUNTERS.valueOf(oaf.getEntity().getType().toString())).increment(1); |
... | ... | |
169 | 167 |
|
170 | 168 |
if (!relMap.isEmpty()) { |
171 | 169 |
for (Entry<String, String> rel : relMap.entries()) { |
172 |
// Text TextKeyOut; |
|
173 |
// |
|
174 |
// switch (oaf.getEntity().getType()) { |
|
175 |
// case project: |
|
176 |
// case datasource: |
|
177 |
// case organization: |
|
178 |
// TextKeyOut = new Text(rel.getKey() + "," + serializer.getId(oaf)); |
|
179 |
// break; |
|
180 |
// case result: |
|
181 |
// default: |
|
182 |
// TextKeyOut = new Text(rel.getKey() + "," + id); |
|
183 |
// break; |
|
184 |
// } |
|
170 |
Text TextKeyOut; |
|
185 | 171 |
|
186 |
//TODO here output |
|
187 |
Text TextKeyOut = new Text(rel.getKey() + "," + serializer.getId(oaf)); |
|
172 |
switch (oaf.getEntity().getType()) { |
|
173 |
case project: |
|
174 |
case datasource: |
|
175 |
case organization: |
|
176 |
TextKeyOut = new Text(rel.getKey() + "," + serializer.getId(oaf)); |
|
177 |
break; |
|
178 |
case result: |
|
179 |
default: |
|
180 |
TextKeyOut = new Text(rel.getKey() + "," + id); |
|
181 |
break; |
|
182 |
} |
|
183 |
|
|
188 | 184 |
context.write((TextKeyOut), new ImmutableBytesWritable(rel.getValue().getBytes())); |
189 | 185 |
} |
190 | 186 |
} |
Also available in: Unified diff
using int ids in results