Sha256: 914935fe3426df7cad4df601c6448b694d5d133ae494401e37d6455b2e76a81e

Contents?: true

Size: 919 Bytes

Versions: 52

Compression:

Stored size: 919 Bytes

Contents

package org.embulk.spi;

import java.util.List;

public class Page
{
    private final Buffer buffer;
    private List<String> stringReferences;

    protected Page(Buffer buffer)
    {
        this.buffer = buffer;
    }

    public static Page allocate(int length)
    {
        return new Page(Buffer.allocate(length));
    }

    public static Page wrap(Buffer buffer)
    {
        return new Page(buffer);
    }

    public Page setStringReferences(List<String> values)
    {
        this.stringReferences = values;
        return this;
    }

    public List<String> getStringReferences()
    {
        // TODO used by mapreduce executor
        return stringReferences;
    }

    public String getStringReference(int index)
    {
        return stringReferences.get(index);
    }

    public void release()
    {
        buffer.release();
    }

    public Buffer buffer()
    {
        return buffer;
    }
}

Version data entries

52 entries across 52 versions & 1 rubygems

Version Path
embulk-0.7.11 embulk-core/src/main/java/org/embulk/spi/Page.java
embulk-0.7.11-java embulk-core/src/main/java/org/embulk/spi/Page.java
embulk-0.7.10 embulk-core/src/main/java/org/embulk/spi/Page.java
embulk-0.7.10-java embulk-core/src/main/java/org/embulk/spi/Page.java
embulk-0.7.9 embulk-core/src/main/java/org/embulk/spi/Page.java
embulk-0.7.9-java embulk-core/src/main/java/org/embulk/spi/Page.java
embulk-0.7.8 embulk-core/src/main/java/org/embulk/spi/Page.java
embulk-0.7.8-java embulk-core/src/main/java/org/embulk/spi/Page.java
embulk-0.7.7 embulk-core/src/main/java/org/embulk/spi/Page.java
embulk-0.7.7-java embulk-core/src/main/java/org/embulk/spi/Page.java
embulk-0.7.6 embulk-core/src/main/java/org/embulk/spi/Page.java
embulk-0.7.6-java embulk-core/src/main/java/org/embulk/spi/Page.java
embulk-0.7.5 embulk-core/src/main/java/org/embulk/spi/Page.java
embulk-0.7.5-java embulk-core/src/main/java/org/embulk/spi/Page.java
embulk-0.6.27 embulk-core/src/main/java/org/embulk/spi/Page.java
embulk-0.7.4 embulk-core/src/main/java/org/embulk/spi/Page.java
embulk-0.7.4-java embulk-core/src/main/java/org/embulk/spi/Page.java
embulk-0.7.3 embulk-core/src/main/java/org/embulk/spi/Page.java
embulk-0.7.3-java embulk-core/src/main/java/org/embulk/spi/Page.java
embulk-0.7.2 embulk-core/src/main/java/org/embulk/spi/Page.java