List of toSerialString() Examples

Examples of toSerialString()

com.asakusafw.runtime.util.VariableTable.toSerialString()
この変数表の内容を、 {@link #defineVariables(String)}で利用可能な文字列に変換して返す。 @return 変数表の内容 @throws IllegalArgumentException 引数に{@code null}が指定された場合

Examples of com.asakusafw.runtime.util.VariableTable.toSerialString()

            Precondition.checkMustNotBeNull(variables, "variables"); //$NON-NLS-1$
            this.homePathPrefix = homePathPrefix;
            this.executionId = executionId;
            VariableTable table = new VariableTable();
            table.defineVariables(variables);
            this.variableList = table.toSerialString();
        }


        /**
         * コマンドホームディレクトリの接頭辞を返す。
         * @return コマンドホームディレクトリの接頭辞

View Full Code Here

Examples of com.asakusafw.runtime.util.VariableTable.toSerialString()

        if (batchArguments.isEmpty() == false) {
            VariableTable variables = new VariableTable(RedefineStrategy.OVERWRITE);
            for (Map.Entry<String, String> entry : batchArguments.entrySet()) {
                variables.defineVariable(entry.getKey(), entry.getValue());
            }
            conf.set(StageConstants.PROP_ASAKUSA_BATCH_ARGS, variables.toSerialString());
        }


        manager = new RuntimeResourceManager(conf);
        try {
            manager.setup();

View Full Code Here

Examples of com.asakusafw.runtime.util.VariableTable.toSerialString()

        VariableTable resolver = new VariableTable(RedefineStrategy.ERROR);
        resolver.defineVariables(context.getBatchArgs());
        Map<String, String> dPropMap = Maps.create();
        dPropMap.put(StageConstants.PROP_USER, context.getOsUser());
        dPropMap.put(StageConstants.PROP_EXECUTION_ID, context.getExecutionId());
        dPropMap.put(StageConstants.PROP_ASAKUSA_BATCH_ARGS, resolver.toSerialString());
        dPropMap.putAll(context.getExtraConfigurations());
        return dPropMap;
    }


    private ExecutionContext createExecutionContext(FlowScript flow, ExecutionPhase phase) {

View Full Code Here

Examples of com.asakusafw.runtime.util.VariableTable.toSerialString()

        } else {
            variables.defineVariables(arguments);
        }


        // replace variables
        configuration.set(PROP_ASAKUSA_BATCH_ARGS, variables.toSerialString());
        return variables;
    }
}

View Full Code Here

Examples of com.asakusafw.runtime.util.VariableTable.toSerialString()

        VariableTable table = new VariableTable();
        table.defineVariable("user_name", "asakusa");
        table.defineVariable("user_pass", "hadoop");
        Map<String, String> env = new HashMap<String, String>();
        env.put(Constants.THUNDER_GATE_HOME, System.getenv(Constants.THUNDER_GATE_HOME));
        env.put(Constants.ENV_ARGS, table.toSerialString());
        ConfigurationLoader.setEnv(env);


        JobFlowParamLoader loder = new JobFlowParamLoader(){
            @Override
            protected Properties getImportProp(File dslFile, String targetName) throws IOException {

View Full Code Here

Examples of com.asakusafw.runtime.util.VariableTable.toSerialString()

        // 環境変数を設定
        VariableTable table = new VariableTable();
        table.defineVariable("user_pass", "hadoop");
        Map<String, String> env = new HashMap<String, String>();
        env.put(Constants.THUNDER_GATE_HOME, System.getenv(Constants.THUNDER_GATE_HOME));
        env.put(Constants.ENV_ARGS, table.toSerialString());
        ConfigurationLoader.setEnv(env);


        JobFlowParamLoader loder = new JobFlowParamLoader(){
            @Override
            protected Properties getImportProp(File dslFile, String targetName) throws IOException {

View Full Code Here

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.