Contents

package org.embulk.formatter.avro.converter;

import org.apache.avro.Schema;
import org.msgpack.value.Value;

abstract public class AbstractAvroValueConverter {
    protected Schema avroSchema;

    public AbstractAvroValueConverter(Schema schema) {
        this.avroSchema = schema;
    }

    public Object booleanColumn(boolean value) {
        throw new RuntimeException(String.format("%s cannot convert to %s of %s field", value, avroSchema.getType(), avroSchema.getName()));
    }

    public Object longColumn(long value) {
        throw new RuntimeException(String.format("%s cannot convert to %s of %s field", value, avroSchema.getType(), avroSchema.getName()));
    }

    public Object doubleColumn(double value) {
        throw new RuntimeException(String.format("%s cannot convert to %s of %s field", value, avroSchema.getType(), avroSchema.getName()));
    }

    public Object stringColumn(String value) {
        throw new RuntimeException(String.format("%s cannot convert to %s of %s field", value, avroSchema.getType(), avroSchema.getName()));
    }

    public Object timestampColumn(String value) {
        throw new RuntimeException(String.format("%s cannot convert to %s of %s field", value, avroSchema.getType(), avroSchema.getName()));
    }

    public Object jsonColumn(Value value) {
        throw new RuntimeException(String.format("%s cannot convert to %s of %s field", value, avroSchema.getType(), avroSchema.getName()));
    }
}

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
embulk-formatter-avro-0.2.1	src/main/java/org/embulk/formatter/avro/converter/AbstractAvroValueConverter.java
embulk-formatter-avro-0.1.1	src/main/java/org/embulk/formatter/avro/converter/AbstractAvroValueConverter.java
embulk-formatter-avro-0.1.0	src/main/java/org/embulk/formatter/avro/converter/AbstractAvroValueConverter.java