blob: 7a1d9bb29aab000799f6b849c90a6eff2b8fe3dc [file] [log] [blame]
/*
* Copyright 2019, Verizon Media.
* Licensed under the terms of the Apache License 2.0. See LICENSE file at the project root for terms.
*/
package com.yahoo.sketches.pig.quantiles;
import java.io.IOException;
import java.util.Comparator;
import org.apache.pig.EvalFunc;
import org.apache.pig.data.DataByteArray;
import org.apache.pig.data.Tuple;
import com.yahoo.memory.Memory;
import com.yahoo.sketches.ArrayOfStringsSerDe;
import com.yahoo.sketches.quantiles.ItemsSketch;
/**
* This UDF is to get a human-readable summary of a given sketch.
*/
public class StringsSketchToString extends EvalFunc<String> {
@Override
public String exec(final Tuple input) throws IOException {
if (input == null) {
return null;
}
if (input.size() != 1) {
throw new IllegalArgumentException("expected one input");
}
if (!(input.get(0) instanceof DataByteArray)) {
throw new IllegalArgumentException("expected a DataByteArray as a sketch, got "
+ input.get(0).getClass().getSimpleName());
}
final DataByteArray dba = (DataByteArray) input.get(0);
final ItemsSketch<String> sketch =
ItemsSketch.getInstance(Memory.wrap(dba.get()), Comparator.naturalOrder(),
new ArrayOfStringsSerDe());
return sketch.toString();
}
}