Java StandardTypes类代码示例

OGeek|极客世界-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中com.facebook.presto.spi.type.StandardTypes类的典型用法代码示例。如果您正苦于以下问题：Java StandardTypes类的具体用法？Java StandardTypes怎么用？Java StandardTypes使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

StandardTypes类属于com.facebook.presto.spi.type包，在下文中一共展示了StandardTypes类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: parseAgent

import com.facebook.presto.spi.type.StandardTypes; //导入依赖的package包/类
@ScalarFunction("parse_agent")
@Description("Returns Map, which has keys such as 'category', 'name', 'os', 'version', 'vendor' and 'os_version'")
@SqlType("map<varchar,varchar>")
public Block parseAgent(@TypeParameter("map<varchar,varchar>") Type mapType, @SqlType(StandardTypes.VARCHAR) Slice slice) {
    String argument = slice.toStringUtf8();
    Map<String, String> stringMap = Classifier.parse(argument);

    if (pageBuilder.isFull()) {
        pageBuilder.reset();
    }

    BlockBuilder blockBuilder = pageBuilder.getBlockBuilder(0);
    BlockBuilder singleMapBlockBuilder = blockBuilder.beginBlockEntry();
    for (Map.Entry<String, String> entry : stringMap.entrySet()) {
        VARCHAR.writeSlice(singleMapBlockBuilder, Slices.utf8Slice(entry.getKey()));
        VARCHAR.writeSlice(singleMapBlockBuilder, Slices.utf8Slice(entry.getValue()));
    }
    blockBuilder.closeEntry();
    pageBuilder.declarePosition();

    return (Block) mapType.getObject(blockBuilder, blockBuilder.getPositionCount() - 1);
}

开发者ID:wyukawa，项目名称:presto-woothee，代码行数:23，代码来源:ParseAgentFuntion.java

示例2: geohash_encode_dec

import com.facebook.presto.spi.type.StandardTypes; //导入依赖的package包/类
@SqlType(StandardTypes.VARCHAR)
@TypeParameterContainer({@TypeParameter("decimal(lat_precision, lat_scale)")
        , @TypeParameter("decimal(lng_precision, lng_scale)")}
)
@Nullable
public static Slice geohash_encode_dec(
        @TypeParameter("decimal(lat_precision, lat_scale)") DecimalType latParameter,
        @TypeParameter("decimal(lng_precision, lng_scale)") DecimalType lngParameter,
        @SqlType("decimal(lat_precision, lat_scale)") Slice lat,
        @SqlType("decimal(lng_precision, lng_scale)") Slice lng,
        @SqlType(StandardTypes.INTEGER) long precision) {


    BigDecimal biglat = new BigDecimal(Decimals.decodeUnscaledValue(lat), latParameter.getScale());
    BigDecimal bigLng = new BigDecimal(Decimals.decodeUnscaledValue(lng), lngParameter.getScale());

    return GeohashEncode.geohash_encode(biglat.doubleValue(), bigLng.doubleValue(), precision);
}

开发者ID:Cuebiq，项目名称:presto-cuebiq-functions，代码行数:19，代码来源:DecimalGeographicFunctions.java

示例3: testMinDoubleDouble

import com.facebook.presto.spi.type.StandardTypes; //导入依赖的package包/类
@Test
public void testMinDoubleDouble()
        throws Exception
{
    InternalAggregationFunction function = METADATA.getFunctionRegistry().getAggregateFunctionImplementation(new Signature("min_by", AGGREGATE, StandardTypes.DOUBLE, StandardTypes.DOUBLE, StandardTypes.DOUBLE));
    assertAggregation(
            function,
            1.0,
            null,
            createDoublesBlock(null, null),
            createDoublesBlock(null, null));

    assertAggregation(
            function,
            1.0,
            3.0,
            createDoublesBlock(3.0, 2.0, 5.0, 3.0),
            createDoublesBlock(1.0, 1.5, 2.0, 4.0));
}

开发者ID:y-lan，项目名称:presto，代码行数:20，代码来源:TestMinMaxByAggregation.java

示例4: input

import com.facebook.presto.spi.type.StandardTypes; //导入依赖的package包/类
@InputFunction
public static void input(EvaluateClassifierPredictionsState state, @SqlType(StandardTypes.VARCHAR) Slice truth, @SqlType(StandardTypes.VARCHAR) Slice prediction)
{
    if (truth.equals(prediction)) {
        String key = truth.toStringUtf8();
        if (!state.getTruePositives().containsKey(key)) {
            state.addMemoryUsage(truth.length() + SIZE_OF_INT);
        }
        state.getTruePositives().put(key, state.getTruePositives().getOrDefault(key, 0) + 1);
    }
    else {
        String truthKey = truth.toStringUtf8();
        String predictionKey = prediction.toStringUtf8();
        if (!state.getFalsePositives().containsKey(predictionKey)) {
            state.addMemoryUsage(prediction.length() + SIZE_OF_INT);
        }
        state.getFalsePositives().put(predictionKey, state.getFalsePositives().getOrDefault(predictionKey, 0) + 1);
        if (!state.getFalseNegatives().containsKey(truthKey)) {
            state.addMemoryUsage(truth.length() + SIZE_OF_INT);
        }
        state.getFalseNegatives().put(truthKey, state.getFalseNegatives().getOrDefault(truthKey, 0) + 1);
    }
}

开发者ID:y-lan，项目名称:presto，代码行数:24，代码来源:EvaluateClassifierPredictionsAggregation.java

示例5: testMaxDoubleVarchar

import com.facebook.presto.spi.type.StandardTypes; //导入依赖的package包/类
@Test
public void testMaxDoubleVarchar()
{
    InternalAggregationFunction function = METADATA.getFunctionRegistry().getAggregateFunctionImplementation(new Signature("max_by", AGGREGATE, StandardTypes.VARCHAR, StandardTypes.VARCHAR, StandardTypes.DOUBLE));
    assertAggregation(
            function,
            1.0,
            "a",
            createStringsBlock("z", "a", null),
            createDoublesBlock(1.0, 2.0, null));

    assertAggregation(
            function,
            1.0,
            "hi",
            createStringsBlock("zz", "hi", null, "a"),
            createDoublesBlock(0.0, 1.0, null, -1.0));
}

开发者ID:y-lan，项目名称:presto，代码行数:19，代码来源:TestMinMaxByAggregation.java

示例6: regexpExtract

import com.facebook.presto.spi.type.StandardTypes; //导入依赖的package包/类
@Nullable
@Description("returns regex group of extracted string with a pattern")
@ScalarFunction
@SqlType(StandardTypes.VARCHAR)
public static Slice regexpExtract(@SqlType(StandardTypes.VARCHAR) Slice source, @SqlType(RegexpType.NAME) Regex pattern, @SqlType(StandardTypes.BIGINT) long groupIndex)
{
    Matcher matcher = pattern.matcher(source.getBytes());
    validateGroup(groupIndex, matcher.getEagerRegion());
    int group = Ints.checkedCast(groupIndex);

    int offset = matcher.search(0, source.length(), Option.DEFAULT);
    if (offset == -1) {
        return null;
    }
    Region region = matcher.getEagerRegion();
    int beg = region.beg[group];
    int end = region.end[group];
    if (beg == -1) {
        // end == -1 must be true
        return null;
    }

    Slice slice = source.slice(beg, end - beg);
    return slice;
}

开发者ID:y-lan，项目名称:presto，代码行数:26，代码来源:RegexpFunctions.java

示例7: testDuplicateKeysValues

import com.facebook.presto.spi.type.StandardTypes; //导入依赖的package包/类
@Test
public void testDuplicateKeysValues()
        throws Exception
{
    MapType mapType = new MapType(DOUBLE, VARCHAR);
    InternalAggregationFunction aggFunc = metadata.getFunctionRegistry().getAggregateFunctionImplementation(new Signature(NAME, AGGREGATE, mapType.getTypeSignature().toString(), StandardTypes.DOUBLE, StandardTypes.VARCHAR));
    assertAggregation(
            aggFunc,
            1.0,
            ImmutableMap.of(1.0, "a"),
            createDoublesBlock(1.0, 1.0, 1.0),
            createStringsBlock("a", "b", "c"));

    mapType = new MapType(DOUBLE, BIGINT);
    aggFunc = metadata.getFunctionRegistry().getAggregateFunctionImplementation(new Signature(NAME, AGGREGATE, mapType.getTypeSignature().toString(), StandardTypes.DOUBLE, StandardTypes.BIGINT));
    assertAggregation(
            aggFunc,
            1.0,
            ImmutableMap.of(1.0, 99L, 2.0, 99L, 3.0, 99L),
            createDoublesBlock(1.0, 2.0, 3.0),
            createLongsBlock(99L, 99L, 99L));
}

开发者ID:y-lan，项目名称:presto，代码行数:23，代码来源:TestMapAggAggregation.java

示例8: bloomFilterPersist

import com.facebook.presto.spi.type.StandardTypes; //导入依赖的package包/类
@SqlType(StandardTypes.BOOLEAN)
@Nullable
@SqlNullable
public static Boolean bloomFilterPersist(@SqlNullable @SqlType(BloomFilterType.TYPE) Slice bloomFilterSlice, @SqlType(StandardTypes.VARCHAR) Slice urlSlice) throws Exception
{
    // Nothing todo
    if (urlSlice == null) {
        return true;
    }
    BloomFilter bf = getOrLoadBloomFilter(bloomFilterSlice);

    // Persist
    // we do not try catch here to make sure that errors are communicated clearly to the client
    // and typical retry logic continues to work
    String url = new String(urlSlice.getBytes());
    if (!HTTP_CLIENT.isStarted()) {
        log.warn("Http client was not started, trying to start");
        HTTP_CLIENT.start();
    }
    Request post = HTTP_CLIENT.POST(url);
    post.content(new StringContentProvider(new String(bf.toBase64())));
    post.method("PUT");
    post.send();
    log.info("Persisted " + bf.toString() + " " + url);
    return true;
}

开发者ID:RobinUS2，项目名称:presto-bloomfilter，代码行数:27，代码来源:BloomFilterPersistScalarFunction.java