Contents

package org.embulk.filter.calcite.adapter.page;

import java.util.Map;
import org.apache.calcite.schema.SchemaFactory;
import org.apache.calcite.schema.SchemaPlus;

/**
 * Factory that creates a {@link PageSchema}.
 *
 * @see https://github.com/apache/calcite/blob/master/example/csv/src/main/java/org/apache/calcite/adapter/csv/CsvSchemaFactory.java
 */
public class PageSchemaFactory
        implements SchemaFactory {

    public static final PageSchemaFactory INSTANCE = new PageSchemaFactory();

    private PageSchemaFactory() {
    }

    @Override
    public org.apache.calcite.schema.Schema create(SchemaPlus parentSchema, String name,
                                                   Map<String, Object> operand) {
        return new PageSchema();
    }
}

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
embulk-filter-calcite-0.2.0	src/main/java/org/embulk/filter/calcite/adapter/page/PageSchemaFactory.java
embulk-filter-calcite-0.1.3	src/main/java/org/embulk/filter/calcite/adapter/page/PageSchemaFactory.java
embulk-filter-calcite-0.1.2	src/main/java/org/embulk/filter/calcite/adapter/page/PageSchemaFactory.java