Contents

package org.embulk.formatter.avro.converter;

import org.apache.avro.Schema;
import org.apache.avro.generic.GenericData;
import org.apache.avro.generic.GenericEnumSymbol;

import java.util.List;

public class AvroEnumConverter extends AbstractAvroValueConverter {
    private List<String> enumSymbols;

    AvroEnumConverter(Schema schema, List<String> enumSymbols) {
        super(schema);
        this.enumSymbols = enumSymbols;
    }

    @Override
    public GenericEnumSymbol stringColumn(String value) {
        if (enumSymbols.contains(value)) {
            return new GenericData.EnumSymbol(avroSchema, value);
        } else {
            throw new RuntimeException(String.format("%s is not in %s", value, enumSymbols.toString()));
        }
    }
}

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/AvroEnumConverter.java
embulk-formatter-avro-0.1.1	src/main/java/org/embulk/formatter/avro/converter/AvroEnumConverter.java
embulk-formatter-avro-0.1.0	src/main/java/org/embulk/formatter/avro/converter/AvroEnumConverter.java