Contents

package org.embulk.output.snowflake;

import com.google.common.base.Optional;
import org.embulk.output.SnowflakeOutputPlugin;

import java.text.SimpleDateFormat;
import java.util.Date;

public class StageIdentifierHolder {
    private static final String pattern = "yyyyMMdd";
    private static final SimpleDateFormat simpleDateFormat = new SimpleDateFormat(pattern);
    private static final String date = simpleDateFormat.format(new Date());
    private static final String salt = SnowflakeUtils.randomString(6);
    private static final String snowflakeStageName = "embulk_snowflake_" + date + salt;
    private static final String snowflakeDestPrefix = date + "_" + salt;

    public static StageIdentifier getStageIdentifier(SnowflakeOutputPlugin.SnowflakePluginTask t){
        return new StageIdentifier(t.getDatabase(), t.getSchema(), snowflakeStageName, Optional.of(snowflakeDestPrefix));
    }
}

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
embulk-output-snowflake-0.2.0	src/main/java/org/embulk/output/snowflake/StageIdentifierHolder.java