Package com.asakusafw.runtime.util

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

354
355
356
357
358
359
360
361
362
363
364
    private void dumpCleaner(Context context, JobflowModel model) {
        assert context != null;
        assert model != null;
        VariableTable variables = new VariableTable();
        variables.defineVariable(StageConstants.VAR_USER, "$USER");
        variables.defineVariable(StageConstants.VAR_BATCH_ID, "$" + VAR_BATCH_ID);
        variables.defineVariable(StageConstants.VAR_FLOW_ID, "$" + VAR_FLOW_ID);
        variables.defineVariable(StageConstants.VAR_EXECUTION_ID, EXPR_EXECUTION_ID);
        String path = getEnvironment().getConfiguration().getRootLocation().toPath('/');
        try {
            String parsed = variables.parse(path, true);
View Full Code Here
355
356
357
358
359
360
361
362
363
364
365
        assert context != null;
        assert model != null;
        VariableTable variables = new VariableTable();
        variables.defineVariable(StageConstants.VAR_USER, "$USER");
        variables.defineVariable(StageConstants.VAR_BATCH_ID, "$" + VAR_BATCH_ID);
        variables.defineVariable(StageConstants.VAR_FLOW_ID, "$" + VAR_FLOW_ID);
        variables.defineVariable(StageConstants.VAR_EXECUTION_ID, EXPR_EXECUTION_ID);
        String path = getEnvironment().getConfiguration().getRootLocation().toPath('/');
        try {
            String parsed = variables.parse(path, true);
            context.put("# Cleaner");
View Full Code Here
356
357
358
359
360
361
362
363
364
365
366
        assert model != null;
        VariableTable variables = new VariableTable();
        variables.defineVariable(StageConstants.VAR_USER, "$USER");
        variables.defineVariable(StageConstants.VAR_BATCH_ID, "$" + VAR_BATCH_ID);
        variables.defineVariable(StageConstants.VAR_FLOW_ID, "$" + VAR_FLOW_ID);
        variables.defineVariable(StageConstants.VAR_EXECUTION_ID, EXPR_EXECUTION_ID);
        String path = getEnvironment().getConfiguration().getRootLocation().toPath('/');
        try {
            String parsed = variables.parse(path, true);
            context.put("# Cleaner");
            context.put("echo \"cleaning job temporary resources\"");
View Full Code Here
775
776
777
778
779
780
781
782
783
784
785
                return false;
            } else {
                try {
                    // 有効なパスかチェック
                    VariableTable variables = Constants.createVariableTable();
                    variables.defineVariable(Constants.HDFS_PATH_VARIABLE_USER, "dummyuser");
                    variables.defineVariable(Constants.HDFS_PATH_VARIABLE_EXECUTION_ID, "dummyid");
                    String dummyPath = variables.parse(path, false);
                    new URI(dummyPath).normalize();
                } catch (URISyntaxException e) {
                    LOG.error(e, "TG-COMMON-00004",
View Full Code Here
776
777
778
779
780
781
782
783
784
785
786
            } else {
                try {
                    // 有効なパスかチェック
                    VariableTable variables = Constants.createVariableTable();
                    variables.defineVariable(Constants.HDFS_PATH_VARIABLE_USER, "dummyuser");
                    variables.defineVariable(Constants.HDFS_PATH_VARIABLE_EXECUTION_ID, "dummyid");
                    String dummyPath = variables.parse(path, false);
                    new URI(dummyPath).normalize();
                } catch (URISyntaxException e) {
                    LOG.error(e, "TG-COMMON-00004",
                            "HDFS上に書き出す際のファイルパスが有効でない",
View Full Code Here
939
940
941
942
943
944
945
946
947
948
949
                        return false;
                    } else {
                        try {
                            // 有効なパスかチェック
                            VariableTable variables = Constants.createVariableTable();
                            variables.defineVariable(Constants.HDFS_PATH_VARIABLE_USER, "dummyuser");
                            variables.defineVariable(Constants.HDFS_PATH_VARIABLE_EXECUTION_ID, "dummyid");
                            String dummyPath = variables.parse(element, false);
                            new URI(dummyPath).normalize();
                        } catch (URISyntaxException e) {
                            LOG.error(e, "TG-COMMON-00005",
View Full Code Here
940
941
942
943
944
945
946
947
948
949
950
                    } else {
                        try {
                            // 有効なパスかチェック
                            VariableTable variables = Constants.createVariableTable();
                            variables.defineVariable(Constants.HDFS_PATH_VARIABLE_USER, "dummyuser");
                            variables.defineVariable(Constants.HDFS_PATH_VARIABLE_EXECUTION_ID, "dummyid");
                            String dummyPath = variables.parse(element, false);
                            new URI(dummyPath).normalize();
                        } catch (URISyntaxException e) {
                            LOG.error(e, "TG-COMMON-00005",
                                    "HDFS上のディレクトリが有効でない",
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
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.