Sha256: db5f026477ec24a7ac9ee80f9653feeae3797178ca1041bb8c7cfb2f73f3799d
Contents?: true
Size: 1.49 KB
Versions: 24
Compression:
Stored size: 1.49 KB
Contents
package org.embulk.spi.type;
import java.util.Map;
import java.io.IOException;
import com.google.common.base.Joiner;
import com.google.common.collect.ImmutableMap;
import com.fasterxml.jackson.databind.DeserializationContext;
import com.fasterxml.jackson.databind.deser.std.FromStringDeserializer;
import com.fasterxml.jackson.databind.JsonMappingException;
public class TypeDeserializer
extends FromStringDeserializer<Type>
{
private static final Map<String, Type> stringToTypeMap;
static {
ImmutableMap.Builder<String, Type> builder = ImmutableMap.builder();
builder.put(BooleanType.BOOLEAN.getName(), BooleanType.BOOLEAN);
builder.put(LongType.LONG.getName(), LongType.LONG);
builder.put(DoubleType.DOUBLE.getName(), DoubleType.DOUBLE);
builder.put(StringType.STRING.getName(), StringType.STRING);
builder.put(TimestampType.TIMESTAMP.getName(), TimestampType.TIMESTAMP);
stringToTypeMap = builder.build();
}
public TypeDeserializer()
{
super(Type.class);
}
@Override
protected Type _deserialize(String value, DeserializationContext context)
throws IOException
{
Type t = stringToTypeMap.get(value);
if (t == null) {
throw new JsonMappingException(
String.format("Unknown type name '%s'. Supported types are: %s",
value,
Joiner.on(", ").join(stringToTypeMap.keySet())));
}
return t;
}
}
Version data entries
24 entries across 24 versions & 1 rubygems