本文整理汇总了Java中com.facebook.presto.spi.type.BigintType类的典型用法代码示例。如果您正苦于以下问题:Java BigintType类的具体用法?Java BigintType怎么用?Java BigintType使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
BigintType类属于com.facebook.presto.spi.type包,在下文中一共展示了BigintType类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: testTopicHasData
import com.facebook.presto.spi.type.BigintType; //导入依赖的package包/类
@Test
public void testTopicHasData()
throws Exception
{
MaterializedResult result = queryRunner.execute("SELECT count(1) from " + topicName);
MaterializedResult expected = MaterializedResult.resultBuilder(SESSION, BigintType.BIGINT)
.row(0)
.build();
assertEquals(result, expected);
int count = 1000;
createMessages(topicName, count);
result = queryRunner.execute("SELECT count(1) from " + topicName);
expected = MaterializedResult.resultBuilder(SESSION, BigintType.BIGINT)
.row(count)
.build();
assertEquals(result, expected);
}
开发者ID:y-lan,项目名称:presto,代码行数:24,代码来源:TestMinimalFunctionality.java
示例2: jdbcType
import com.facebook.presto.spi.type.BigintType; //导入依赖的package包/类
public static JDBCType jdbcType(Type type)
{
if (type.equals(BooleanType.BOOLEAN)) {
return JDBCType.BOOLEAN;
}
if (type.equals(BigintType.BIGINT) || type.equals(TimestampType.TIMESTAMP)) {
return JDBCType.BIGINT;
}
if (type.equals(DoubleType.DOUBLE)) {
return JDBCType.DOUBLE;
}
if (type.equals(DateType.DATE)) {
return JDBCType.INTEGER;
}
if (type.equals(VarcharType.VARCHAR)) {
return JDBCType.VARBINARY;
}
return null;
}
开发者ID:y-lan,项目名称:presto,代码行数:20,代码来源:ShardPredicate.java
示例3: doComputeColumnStats
import com.facebook.presto.spi.type.BigintType; //导入依赖的package包/类
private static ColumnStats doComputeColumnStats(OrcReader orcReader, long columnId, Type type)
throws IOException
{
int columnIndex = columnIndex(orcReader.getColumnNames(), columnId);
OrcRecordReader reader = orcReader.createRecordReader(ImmutableMap.of(columnIndex, type), OrcPredicate.TRUE, UTC, new AggregatedMemoryContext());
if (type.equals(BooleanType.BOOLEAN)) {
return indexBoolean(type, reader, columnIndex, columnId);
}
if (type.equals(BigintType.BIGINT) ||
type.equals(DateType.DATE) ||
type.equals(TimestampType.TIMESTAMP)) {
return indexLong(type, reader, columnIndex, columnId);
}
if (type.equals(DoubleType.DOUBLE)) {
return indexDouble(type, reader, columnIndex, columnId);
}
if (type.equals(VarcharType.VARCHAR)) {
return indexString(type, reader, columnIndex, columnId);
}
return null;
}
开发者ID:y-lan,项目名称:presto,代码行数:23,代码来源:ShardStats.java
示例4: testTableHasData
import com.facebook.presto.spi.type.BigintType; //导入依赖的package包/类
@Test
public void testTableHasData()
throws Exception
{
MaterializedResult result = queryRunner.execute("SELECT count(1) from " + tableName);
MaterializedResult expected = MaterializedResult.resultBuilder(SESSION, BigintType.BIGINT)
.row(0)
.build();
assertEquals(result, expected);
int count = 1000;
populateData(count);
result = queryRunner.execute("SELECT count(1) from " + tableName);
expected = MaterializedResult.resultBuilder(SESSION, BigintType.BIGINT)
.row(count)
.build();
assertEquals(result, expected);
}
开发者ID:y-lan,项目名称:presto,代码行数:24,代码来源:TestMinimalFunctionality.java
示例5: serializeSessionProperty
import com.facebook.presto.spi.type.BigintType; //导入依赖的package包/类
@NotNull
public static String serializeSessionProperty(Type type, Object value)
{
if (value == null) {
throw new PrestoException(INVALID_SESSION_PROPERTY, "Session property can not be null");
}
if (BooleanType.BOOLEAN.equals(type)) {
return value.toString();
}
if (BigintType.BIGINT.equals(type)) {
return value.toString();
}
if (DoubleType.DOUBLE.equals(type)) {
return value.toString();
}
if (VarcharType.VARCHAR.equals(type)) {
return value.toString();
}
if (type instanceof ArrayType || type instanceof MapType) {
return getJsonCodecForType(type).toJson(value);
}
throw new PrestoException(INVALID_SESSION_PROPERTY, format("Session property type %s is not supported", type));
}
开发者ID:y-lan,项目名称:presto,代码行数:24,代码来源:SessionPropertyManager.java
示例6: deserializeSessionProperty
import com.facebook.presto.spi.type.BigintType; //导入依赖的package包/类
@NotNull
private static Object deserializeSessionProperty(Type type, String value)
{
if (value == null) {
throw new PrestoException(INVALID_SESSION_PROPERTY, "Session property can not be null");
}
if (VarcharType.VARCHAR.equals(type)) {
return value;
}
if (BooleanType.BOOLEAN.equals(type)) {
return Boolean.valueOf(value);
}
if (BigintType.BIGINT.equals(type)) {
return Long.valueOf(value);
}
if (DoubleType.DOUBLE.equals(type)) {
return Double.valueOf(value);
}
if (type instanceof ArrayType || type instanceof MapType) {
return getJsonCodecForType(type).fromJson(value);
}
throw new PrestoException(INVALID_SESSION_PROPERTY, format("Session property type %s is not supported", type));
}
开发者ID:y-lan,项目名称:presto,代码行数:24,代码来源:SessionPropertyManager.java
示例7: getJsonCodecForType
import com.facebook.presto.spi.type.BigintType; //导入依赖的package包/类
private static <T> JsonCodec<T> getJsonCodecForType(Type type)
{
if (VarcharType.VARCHAR.equals(type)) {
return (JsonCodec<T>) JSON_CODEC_FACTORY.jsonCodec(String.class);
}
if (BooleanType.BOOLEAN.equals(type)) {
return (JsonCodec<T>) JSON_CODEC_FACTORY.jsonCodec(Boolean.class);
}
if (BigintType.BIGINT.equals(type)) {
return (JsonCodec<T>) JSON_CODEC_FACTORY.jsonCodec(Long.class);
}
if (DoubleType.DOUBLE.equals(type)) {
return (JsonCodec<T>) JSON_CODEC_FACTORY.jsonCodec(Double.class);
}
if (type instanceof ArrayType) {
Type elementType = ((ArrayType) type).getElementType();
return (JsonCodec<T>) JSON_CODEC_FACTORY.listJsonCodec(getJsonCodecForType(elementType));
}
if (type instanceof MapType) {
Type keyType = ((MapType) type).getKeyType();
Type valueType = ((MapType) type).getValueType();
return (JsonCodec<T>) JSON_CODEC_FACTORY.mapJsonCodec(getMapKeyType(keyType), getJsonCodecForType(valueType));
}
throw new PrestoException(INVALID_SESSION_PROPERTY, format("Session property type %s is not supported", type));
}
开发者ID:y-lan,项目名称:presto,代码行数:26,代码来源:SessionPropertyManager.java
示例8: getMapKeyType
import com.facebook.presto.spi.type.BigintType; //导入依赖的package包/类
private static Class<?> getMapKeyType(Type type)
{
if (VarcharType.VARCHAR.equals(type)) {
return String.class;
}
if (BooleanType.BOOLEAN.equals(type)) {
return Boolean.class;
}
if (BigintType.BIGINT.equals(type)) {
return Long.class;
}
if (DoubleType.DOUBLE.equals(type)) {
return Double.class;
}
throw new PrestoException(INVALID_SESSION_PROPERTY, format("Session property map key type %s is not supported", type));
}
开发者ID:y-lan,项目名称:presto,代码行数:17,代码来源:SessionPropertyManager.java
示例9: visitUnnest
import com.facebook.presto.spi.type.BigintType; //导入依赖的package包/类
@Override
protected RelationType visitUnnest(Unnest node, AnalysisContext context)
{
ImmutableList.Builder<Field> outputFields = ImmutableList.builder();
for (Expression expression : node.getExpressions()) {
ExpressionAnalysis expressionAnalysis = analyzeExpression(expression, context.getLateralTupleDescriptor(), context);
Type expressionType = expressionAnalysis.getType(expression);
if (expressionType instanceof ArrayType) {
outputFields.add(Field.newUnqualified(Optional.empty(), ((ArrayType) expressionType).getElementType()));
}
else if (expressionType instanceof MapType) {
outputFields.add(Field.newUnqualified(Optional.empty(), ((MapType) expressionType).getKeyType()));
outputFields.add(Field.newUnqualified(Optional.empty(), ((MapType) expressionType).getValueType()));
}
else {
throw new PrestoException(INVALID_FUNCTION_ARGUMENT, "Cannot unnest type: " + expressionType);
}
}
if (node.isWithOrdinality()) {
outputFields.add(Field.newUnqualified(Optional.empty(), BigintType.BIGINT));
}
RelationType descriptor = new RelationType(outputFields.build());
analysis.setOutputDescriptor(node, descriptor);
return descriptor;
}
开发者ID:y-lan,项目名称:presto,代码行数:26,代码来源:StatementAnalyzer.java
示例10: testNonExistent
import com.facebook.presto.spi.type.BigintType; //导入依赖的package包/类
@Test
public void testNonExistent()
throws Exception
{
byte[] json = "{}".getBytes(StandardCharsets.UTF_8);
JsonRowDecoder rowDecoder = new JsonRowDecoder(PROVIDER.get());
DecoderTestColumnHandle row1 = new DecoderTestColumnHandle("", 0, "row1", VarcharType.VARCHAR, "very/deep/varchar", null, null, false, false, false);
DecoderTestColumnHandle row2 = new DecoderTestColumnHandle("", 1, "row2", BigintType.BIGINT, "no_bigint", null, null, false, false, false);
DecoderTestColumnHandle row3 = new DecoderTestColumnHandle("", 2, "row3", DoubleType.DOUBLE, "double/is_missing", null, null, false, false, false);
DecoderTestColumnHandle row4 = new DecoderTestColumnHandle("", 3, "row4", BooleanType.BOOLEAN, "hello", null, null, false, false, false);
List<DecoderColumnHandle> columns = ImmutableList.of(row1, row2, row3, row4);
Set<FieldValueProvider> providers = new HashSet<>();
boolean corrupt = rowDecoder.decodeRow(json, null, providers, columns, buildMap(columns));
assertFalse(corrupt);
assertEquals(providers.size(), columns.size());
checkIsNull(providers, row1);
checkIsNull(providers, row2);
checkIsNull(providers, row3);
checkIsNull(providers, row4);
}
开发者ID:y-lan,项目名称:presto,代码行数:26,代码来源:TestJsonDecoder.java
示例11: testStringNumber
import com.facebook.presto.spi.type.BigintType; //导入依赖的package包/类
@Test
public void testStringNumber()
throws Exception
{
byte[] json = "{\"a_number\":481516,\"a_string\":\"2342\"}".getBytes(StandardCharsets.UTF_8);
JsonRowDecoder rowDecoder = new JsonRowDecoder(PROVIDER.get());
DecoderTestColumnHandle row1 = new DecoderTestColumnHandle("", 0, "row1", VarcharType.VARCHAR, "a_number", null, null, false, false, false);
DecoderTestColumnHandle row2 = new DecoderTestColumnHandle("", 1, "row2", BigintType.BIGINT, "a_number", null, null, false, false, false);
DecoderTestColumnHandle row3 = new DecoderTestColumnHandle("", 2, "row3", VarcharType.VARCHAR, "a_string", null, null, false, false, false);
DecoderTestColumnHandle row4 = new DecoderTestColumnHandle("", 3, "row4", BigintType.BIGINT, "a_string", null, null, false, false, false);
List<DecoderColumnHandle> columns = ImmutableList.of(row1, row2, row3, row4);
Set<FieldValueProvider> providers = new HashSet<>();
boolean corrupt = rowDecoder.decodeRow(json, null, providers, columns, buildMap(columns));
assertFalse(corrupt);
assertEquals(providers.size(), columns.size());
checkValue(providers, row1, "481516");
checkValue(providers, row2, 481516);
checkValue(providers, row3, "2342");
checkValue(providers, row4, 2342);
}
开发者ID:y-lan,项目名称:presto,代码行数:26,代码来源:TestJsonDecoder.java
示例12: testNulls
import com.facebook.presto.spi.type.BigintType; //导入依赖的package包/类
@Test
public void testNulls()
{
String csv = ",,,";
CsvRowDecoder rowDecoder = new CsvRowDecoder();
DecoderTestColumnHandle row1 = new DecoderTestColumnHandle("", 0, "row1", VarcharType.VARCHAR, "0", null, null, false, false, false);
DecoderTestColumnHandle row2 = new DecoderTestColumnHandle("", 1, "row2", BigintType.BIGINT, "1", null, null, false, false, false);
DecoderTestColumnHandle row3 = new DecoderTestColumnHandle("", 2, "row3", DoubleType.DOUBLE, "2", null, null, false, false, false);
DecoderTestColumnHandle row4 = new DecoderTestColumnHandle("", 3, "row4", BooleanType.BOOLEAN, "3", null, null, false, false, false);
List<DecoderColumnHandle> columns = ImmutableList.of(row1, row2, row3, row4);
Set<FieldValueProvider> providers = new HashSet<>();
boolean corrupt = rowDecoder.decodeRow(csv.getBytes(StandardCharsets.UTF_8), null, providers, columns, buildMap(columns));
assertFalse(corrupt);
assertEquals(providers.size(), columns.size());
checkValue(providers, row1, "");
checkValue(providers, row2, 0);
checkValue(providers, row3, 0.0d);
checkValue(providers, row4, false);
}
开发者ID:y-lan,项目名称:presto,代码行数:27,代码来源:TestCsvDecoder.java
示例13: testStreamHasData
import com.facebook.presto.spi.type.BigintType; //导入依赖的package包/类
@Test
public void testStreamHasData()
throws Exception
{
MaterializedResult result = queryRunner.execute("Select count(1) from " + dummyStreamName);
MaterializedResult expected = MaterializedResult.resultBuilder(SESSION, BigintType.BIGINT)
.row(0)
.build();
assertEquals(result.getRowCount(), expected.getRowCount());
int count = 500;
createDummyMessages(dummyStreamName, count);
result = queryRunner.execute("SELECT count(1) from " + dummyStreamName);
expected = MaterializedResult.resultBuilder(SESSION, BigintType.BIGINT)
.row(count)
.build();
assertEquals(result.getRowCount(), expected.getRowCount());
log.info("Completed second test (select counts)");
}
开发者ID:qubole,项目名称:presto-kinesis,代码行数:24,代码来源:TestRecordAccess.java
示例14: testNonExistent
import com.facebook.presto.spi.type.BigintType; //导入依赖的package包/类
@Test
public void testNonExistent()
throws Exception
{
byte[] json = "{}".getBytes(StandardCharsets.UTF_8);
JsonKinesisRowDecoder rowDecoder = new JsonKinesisRowDecoder(PROVIDER.get());
KinesisColumnHandle row1 = new KinesisColumnHandle("", 0, "row1", VarcharType.VARCHAR, "very/deep/varchar", null, null, false, false);
KinesisColumnHandle row2 = new KinesisColumnHandle("", 1, "row2", BigintType.BIGINT, "no_bigint", null, null, false, false);
KinesisColumnHandle row3 = new KinesisColumnHandle("", 2, "row3", DoubleType.DOUBLE, "double/is_missing", null, null, false, false);
KinesisColumnHandle row4 = new KinesisColumnHandle("", 3, "row4", BooleanType.BOOLEAN, "hello", null, null, false, false);
List<KinesisColumnHandle> columns = ImmutableList.of(row1, row2, row3, row4);
Set<KinesisFieldValueProvider> providers = new HashSet<>();
boolean valid = rowDecoder.decodeRow(json, providers, columns, buildMap(columns));
assertTrue(valid);
assertEquals(providers.size(), columns.size());
DecoderTestUtil.checkIsNull(providers, row1);
DecoderTestUtil.checkIsNull(providers, row2);
DecoderTestUtil.checkIsNull(providers, row3);
DecoderTestUtil.checkIsNull(providers, row4);
}
开发者ID:qubole,项目名称:presto-kinesis,代码行数:26,代码来源:TestJsonDecoder.java
示例15: testStringNumber
import com.facebook.presto.spi.type.BigintType; //导入依赖的package包/类
@Test
public void testStringNumber()
throws Exception
{
byte[] json = "{\"a_number\":481516,\"a_string\":\"2342\"}".getBytes(StandardCharsets.UTF_8);
JsonKinesisRowDecoder rowDecoder = new JsonKinesisRowDecoder(PROVIDER.get());
KinesisColumnHandle row1 = new KinesisColumnHandle("", 0, "row1", VarcharType.VARCHAR, "a_number", null, null, false, false);
KinesisColumnHandle row2 = new KinesisColumnHandle("", 1, "row2", BigintType.BIGINT, "a_number", null, null, false, false);
KinesisColumnHandle row3 = new KinesisColumnHandle("", 2, "row3", VarcharType.VARCHAR, "a_string", null, null, false, false);
KinesisColumnHandle row4 = new KinesisColumnHandle("", 3, "row4", BigintType.BIGINT, "a_string", null, null, false, false);
List<KinesisColumnHandle> columns = ImmutableList.of(row1, row2, row3, row4);
Set<KinesisFieldValueProvider> providers = new HashSet<>();
boolean valid = rowDecoder.decodeRow(json, providers, columns, buildMap(columns));
assertTrue(valid);
assertEquals(providers.size(), columns.size());
DecoderTestUtil.checkValue(providers, row1, "481516");
DecoderTestUtil.checkValue(providers, row2, 481516);
DecoderTestUtil.checkValue(providers, row3, "2342");
DecoderTestUtil.checkValue(providers, row4, 2342);
}
开发者ID:qubole,项目名称:presto-kinesis,代码行数:26,代码来源:TestJsonDecoder.java
示例16: testStreamHasData
import com.facebook.presto.spi.type.BigintType; //导入依赖的package包/类
@Test
public void testStreamHasData()
throws Exception
{
MaterializedResult result = queryRunner.execute("Select count(1) from " + streamName);
MaterializedResult expected = MaterializedResult.resultBuilder(SESSION, BigintType.BIGINT)
.row(0)
.build();
assertEquals(result, expected);
int count = 500;
createMessages(streamName, count);
result = queryRunner.execute("SELECT count(1) from " + streamName);
expected = MaterializedResult.resultBuilder(SESSION, BigintType.BIGINT)
.row(count)
.build();
assertEquals(result, expected);
}
开发者ID:qubole,项目名称:presto-kinesis,代码行数:24,代码来源:TestMinimalFunctionality.java
示例17: getTableMetadata
import com.facebook.presto.spi.type.BigintType; //导入依赖的package包/类
@Override
public ConnectorTableMetadata getTableMetadata(SchemaTableName schemaTableName)
{
return new ConnectorTableMetadata(
schemaTableName,
ImmutableList.of(
new ColumnMetadata("number", BigintType.BIGINT),
new ColumnMetadata("state", createUnboundedVarcharType()),
new ColumnMetadata("user", createUnboundedVarcharType()),
new ColumnMetadata("title", createUnboundedVarcharType())));
}
开发者ID:prestodb-rocks,项目名称:presto-rest,代码行数:12,代码来源:GithubRest.java
示例18: getTableMetadata
import com.facebook.presto.spi.type.BigintType; //导入依赖的package包/类
@Override
public ConnectorTableMetadata getTableMetadata(SchemaTableName schemaTableName)
{
return new ConnectorTableMetadata(
schemaTableName,
ImmutableList.of(
new ColumnMetadata("id", createUnboundedVarcharType()),
new ColumnMetadata("text", createUnboundedVarcharType()),
new ColumnMetadata("retweet_count", BigintType.BIGINT),
new ColumnMetadata("user_name", createUnboundedVarcharType()),
new ColumnMetadata("user_screen_name", createUnboundedVarcharType())));
}
开发者ID:prestodb-rocks,项目名称:presto-rest,代码行数:13,代码来源:TwitterRest.java
示例19: testManySegments
import com.facebook.presto.spi.type.BigintType; //导入依赖的package包/类
@Test
public void testManySegments()
throws Exception
{
MaterializedResult result = queryRunner.execute("SELECT count(_message) from " + topicName);
MaterializedResult expected = MaterializedResult.resultBuilder(SESSION, BigintType.BIGINT)
.row(100000)
.build();
assertEquals(result, expected);
}
开发者ID:y-lan,项目名称:presto,代码行数:13,代码来源:TestManySegments.java
示例20: testGetTableHandle
import com.facebook.presto.spi.type.BigintType; //导入依赖的package包/类
@Test
public void testGetTableHandle()
throws Exception
{
JmxTableHandle handle = metadata.getTableHandle(SESSION, RUNTIME_TABLE);
assertEquals(handle.getConnectorId(), "test");
assertEquals(handle.getObjectName(), RUNTIME_OBJECT);
List<JmxColumnHandle> columns = handle.getColumns();
assertTrue(columns.contains(new JmxColumnHandle("test", "node", VARCHAR)));
assertTrue(columns.contains(new JmxColumnHandle("test", "Name", VARCHAR)));
assertTrue(columns.contains(new JmxColumnHandle("test", "StartTime", BigintType.BIGINT)));
}
开发者ID:y-lan,项目名称:presto,代码行数:14,代码来源:TestJmxMetadata.java
注:本文中的com.facebook.presto.spi.type.BigintType类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论