Contents

package org.embulk.parser.avro.getter;

import org.embulk.spi.Column;
import org.embulk.spi.PageBuilder;
import org.embulk.spi.time.TimestampParser;
import org.msgpack.value.Value;

public class GenericDataColumnGetter extends BaseColumnGetter {
    public GenericDataColumnGetter(PageBuilder pageBuilder, TimestampParser[] timestampParsers) {
        super(pageBuilder, timestampParsers);
    }

    @Override
    public void stringColumn(Column column) {
        if (this.value == null) {
            pageBuilder.setNull(column);
        }
        else {
            Value converted = AvroGenericDataConverter.convert(value);
            pageBuilder.setString(column, converted.toString());
        }
    }

    @Override
    public void jsonColumn(Column column) {
        if (this.value == null) {
            pageBuilder.setNull(column);
        }
        else {
            Value converted = AvroGenericDataConverter.convert(value);
            pageBuilder.setJson(column, converted);
        }
    }
}

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
embulk-parser-avro-0.4.0	src/main/java/org/embulk/parser/avro/getter/GenericDataColumnGetter.java
embulk-parser-avro-0.3.0	src/main/java/org/embulk/parser/avro/getter/GenericDataColumnGetter.java
embulk-parser-avro-0.2.0	src/main/java/org/embulk/parser/avro/getter/GenericDataColumnGetter.java
embulk-parser-avro-0.1.0	src/main/java/org/embulk/parser/avro/getter/GenericDataColumnGetter.java