You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by bi...@apache.org on 2012/01/30 19:22:43 UTC
svn commit: r1237898 -
/incubator/accumulo/branches/1.4/src/examples/wikisearch/ingest/src/main/java/org/apache/accumulo/examples/wikisearch/util/TextUtil.java
Author: billie
Date: Mon Jan 30 18:22:42 2012
New Revision: 1237898
URL: http://svn.apache.org/viewvc?rev=1237898&view=rev
Log:
ACCUMULO-354 removed aggregator from util
Modified:
incubator/accumulo/branches/1.4/src/examples/wikisearch/ingest/src/main/java/org/apache/accumulo/examples/wikisearch/util/TextUtil.java
Modified: incubator/accumulo/branches/1.4/src/examples/wikisearch/ingest/src/main/java/org/apache/accumulo/examples/wikisearch/util/TextUtil.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/src/examples/wikisearch/ingest/src/main/java/org/apache/accumulo/examples/wikisearch/util/TextUtil.java?rev=1237898&r1=1237897&r2=1237898&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/src/examples/wikisearch/ingest/src/main/java/org/apache/accumulo/examples/wikisearch/util/TextUtil.java (original)
+++ incubator/accumulo/branches/1.4/src/examples/wikisearch/ingest/src/main/java/org/apache/accumulo/examples/wikisearch/util/TextUtil.java Mon Jan 30 18:22:42 2012
@@ -18,8 +18,9 @@ package org.apache.accumulo.examples.wik
import java.nio.ByteBuffer;
import java.nio.charset.CharacterCodingException;
+
+import org.apache.accumulo.core.iterators.user.SummingCombiner;
import org.apache.hadoop.io.Text;
-import org.apache.accumulo.core.iterators.aggregation.LongSummation;
public class TextUtil {
@@ -43,7 +44,7 @@ public class TextUtil {
public static void textAppend(Text t, long s) {
t.append(nullByte, 0, 1);
- t.append(LongSummation.longToBytes(s), 0, 8);
+ t.append(SummingCombiner.FIXED_LEN_ENCODER.encode(s), 0, 8);
}
private static final byte[] nullByte = {0};