fix(TUP-39924): upgrade org.codehaus.plexus:plexus-archiver to 4.8.0, (#6345)

plexus-io to 3.4.1 , maven-assembly-plugin to 3.6.0 and plexus-util to
4.0.0 for incompatibility.

main/plugins/org.talend.common.ui.runtime/src/main/java/org/talend/commons/ui/runtime/image/ECoreImage.java

@@ -115,6 +115,8 @@ public enum ECoreImage implements IImage {
 
     METADATA_SAPCONNECTION_ICON("/icons1/sapconnection.png"), //$NON-NLS-1$
     METADATA_SAPCONNECTION_WIZ("/icons1/connection_wiz.gif"), //$NON-NLS-1$
+    
+    METADATA_BIGQUERYCONNECTION_ICON("/icons1/bigqueryconnection.png"), //$NON-NLS-1$
 
     METADATA_HEADERFOOTER_ICON("/icons1/headerfooter_icon32.png"), //$NON-NLS-1$
 

main/plugins/org.talend.core.repository/src/main/java/org/talend/core/repository/i18n/messages.properties

@@ -156,6 +156,7 @@ ProjectRepositoryNode.invalidItem=Invalid item
 ProjectRepositoryNode.columns=Columns
 ProjectRepositoryNode.validationRules=Validation Rules
 ProjectRepositoryNode.cdcFoundation=CDC Foundation
+ProjectRepositoryNode.cdcFoundation.deprecated=CDC Foundation (deprecated)
 ProjectRepositoryNode.genericSchema=Generic schemas
 ProjectRepositoryNode.queries=Queries
 ProjectRepositoryNode.synonymSchemas=Synonym schemas

main/plugins/org.talend.core.repository/src/main/java/org/talend/core/repository/i18n/messages_ja.properties

@@ -156,6 +156,7 @@ ProjectRepositoryNode.invalidItem=\u7121\u52B9\u306A\u30A2\u30A4\u30C6\u30E0
 ProjectRepositoryNode.columns=\u30AB\u30E9\u30E0
 ProjectRepositoryNode.validationRules=\u691C\u8A3C\u30EB\u30FC\u30EB
 ProjectRepositoryNode.cdcFoundation=CDC Foundation
+ProjectRepositoryNode.cdcFoundation.deprecated=CDC Foundation (\u975E\u63A8\u5968)
 ProjectRepositoryNode.genericSchema=\u30B8\u30A7\u30CD\u30EA\u30C3\u30AF\u30B9\u30AD\u30FC\u30DE
 ProjectRepositoryNode.queries=\u30AF\u30A8\u30EA\u30FC
 ProjectRepositoryNode.synonymSchemas=\u30B7\u30CE\u30CB\u30E0\u30B9\u30AD\u30FC\u30DE

main/plugins/org.talend.core.repository/src/main/java/org/talend/core/repository/model/AbstractEMFRepositoryFactory.java

@@ -130,7 +130,7 @@ public abstract class AbstractEMFRepositoryFactory extends AbstractRepositoryFac
                 ERepositoryObjectType.METADATA_FILE_RULES, ERepositoryObjectType.METADATA_FILE_HL7,
                 ERepositoryObjectType.METADATA_FILE_FTP, ERepositoryObjectType.METADATA_FILE_BRMS,
                 ERepositoryObjectType.METADATA_MDMCONNECTION, ERepositoryObjectType.METADATA_HEADER_FOOTER,
-                ERepositoryObjectType.JOB_SCRIPT };
+                ERepositoryObjectType.JOB_SCRIPT, ERepositoryObjectType.METADATA_BIGQUERYCONNECTIONS };
 
         List<IRepositoryViewObject> deletedItems = new ArrayList<IRepositoryViewObject>();
         for (ERepositoryObjectType type : types) {

main/plugins/org.talend.core.repository/src/main/java/org/talend/core/repository/model/AbstractRepositoryFactory.java

@@ -184,6 +184,7 @@ public abstract class AbstractRepositoryFactory implements IRepositoryFactory {
         collect(getMetadata(project, ERepositoryObjectType.METADATA_FILE_LDIF), result);
         collect(getMetadata(project, ERepositoryObjectType.METADATA_CONNECTIONS), result);
         collect(getMetadata(project, ERepositoryObjectType.METADATA_SAPCONNECTIONS), result);
+        collect(getMetadata(project, ERepositoryObjectType.METADATA_BIGQUERYCONNECTIONS), result);
         collect(getMetadata(project, ERepositoryObjectType.METADATA_HEADER_FOOTER), result);
         collect(getMetadata(project, ERepositoryObjectType.METADATA_LDAP_SCHEMA), result);
         collect(getMetadata(project, ERepositoryObjectType.METADATA_GENERIC_SCHEMA), result);

main/plugins/org.talend.core.repository/src/main/java/org/talend/core/repository/model/ProjectRepositoryNode.java

@@ -1350,6 +1350,8 @@ public class ProjectRepositoryNode extends RepositoryNode implements IProjectRep
             connection = dbMetadataConnection;
         } else if (type == ERepositoryObjectType.METADATA_SAPCONNECTIONS) {
             connection = ((ConnectionItem) repositoryObject.getProperty().getItem()).getConnection();
+        } else if (type == ERepositoryObjectType.METADATA_BIGQUERYCONNECTIONS) {
+            connection = ((ConnectionItem) repositoryObject.getProperty().getItem()).getConnection();
         } else if (type == ERepositoryObjectType.METADATA_FILE_DELIMITED) {
             connection = ((ConnectionItem) repositoryObject.getProperty().getItem()).getConnection();
         } else if (type == ERepositoryObjectType.METADATA_FILE_POSITIONAL) {
@@ -1701,11 +1703,11 @@ public class ProjectRepositoryNode extends RepositoryNode implements IProjectRep
                 DatabaseConnectionItem connectionItem = (DatabaseConnectionItem) item;
                 DatabaseConnection connection = (DatabaseConnection) connectionItem.getConnection();
                 if (PluginChecker.isCDCPluginLoaded()) {
-                    ICDCProviderService service = GlobalServiceRegister.getDefault()
-                            .getService(ICDCProviderService.class);
+                    ICDCProviderService service = GlobalServiceRegister.getDefault().getService(ICDCProviderService.class);
+
                     if (service != null && service.canCreateCDCConnection(connection)) {
                         RepositoryNode cdcNode = new StableRepositoryNode(node,
-                                Messages.getString("ProjectRepositoryNode.cdcFoundation"), //$NON-NLS-1$
+                                Messages.getString("ProjectRepositoryNode.cdcFoundation.deprecated"), //$NON-NLS-1$
                                 ECoreImage.FOLDER_CLOSE_ICON);
                         node.getChildren().add(cdcNode);
                         service.createCDCTypes(recBinNode, cdcNode, connection.getCdcConns());

main/plugins/org.talend.core.repository/src/main/java/org/talend/core/repository/model/ProxyRepositoryFactory.java

@@ -2207,6 +2207,13 @@ public final class ProxyRepositoryFactory implements IProxyRepositoryFactory {
                     ExceptionHandler.process(e);
                 }
                 
+                if (IHadoopDistributionService.get() != null) {
+                    try {
+                        IHadoopDistributionService.get().checkAndMigrateDistributionProxyCredential(project);
+                    } catch (Exception e) {
+                        ExceptionHandler.process(e);
+                    }
+                }
                 // init dynamic distirbution after `beforeLogon`, before loading libraries.
                 initDynamicDistribution(monitor);
                 

main/plugins/org.talend.core.repository/src/main/java/org/talend/core/repository/ui/actions/DuplicateAction.java

@@ -606,6 +606,8 @@ public class DuplicateAction extends AContextualAction {
                     item = PropertiesFactory.eINSTANCE.createSalesforceSchemaConnectionItem();
                 } else if (repositoryType == ERepositoryObjectType.METADATA_SAPCONNECTIONS) {
                     item = PropertiesFactory.eINSTANCE.createSAPConnectionItem();
+                } else if (repositoryType == ERepositoryObjectType.METADATA_BIGQUERYCONNECTIONS) {
+                    item = PropertiesFactory.eINSTANCE.createBigQueryConnectionItem();
                 } else if (repositoryType == ERepositoryObjectType.METADATA_WSDL_SCHEMA) {
                     item = PropertiesFactory.eINSTANCE.createWSDLSchemaConnectionItem();
                 } else if (repositoryType == ERepositoryObjectType.PROCESS) {

main/plugins/org.talend.core.runtime/src/main/java/org/talend/core/PluginChecker.java

@@ -43,6 +43,8 @@ public class PluginChecker {
     private static final String CDC_PLUGIN_ID = "org.talend.designer.cdc"; //$NON-NLS-1$
 
     private static final String SAP_WZIARD_PLUGIN_ID = "org.talend.repository.sap"; //$NON-NLS-1$
+    
+    private static final String BIGQUERY_WZIARD_PLUGIN_ID = "org.talend.repository.bigquery"; //$NON-NLS-1$
 
     private static final String EBCDIC_PLUGIN_ID = "org.talend.repository.ebcdic"; //$NON-NLS-1$
 
@@ -246,6 +248,10 @@ public class PluginChecker {
     public static boolean isSAPWizardPluginLoaded() {
         return isPluginLoaded(SAP_WZIARD_PLUGIN_ID);
     }
+    
+    public static boolean isBigQueryWizardPluginLoaded() {
+        return isPluginLoaded(BIGQUERY_WZIARD_PLUGIN_ID);
+    }
 
     public static boolean isEBCDICPluginLoaded() {
         return isPluginLoaded(EBCDIC_PLUGIN_ID);

main/plugins/org.talend.core.runtime/src/main/java/org/talend/core/database/conn/ConnParameterKeys.java

@@ -455,6 +455,9 @@ public class ConnParameterKeys {
     public static final String CONN_PARA_KEY_UNIV_STANDALONE_EXEC_MEMORY="CONN_PARA_KEY_UNIV_STANDALONE_EXEC_MEMORY";
     public static final String CONN_PARA_KEY_UNIV_STANDALONE_EXEC_CORE="CONN_PARA_KEY_UNIV_STANDALONE_EXEC_CORE";
     
+    
+    // Spark Submit Scripts
+    public static final String CONN_PARA_KEY_UNIV_SPARK_SUBMIT_SCRIPT_HOME="CONN_PARA_KEY_UNIV_SPARK_SUBMIT_SCRIPT_HOME";
     /**
      * Redshift
      */

main/plugins/org.talend.core.runtime/src/main/java/org/talend/core/database/conn/version/EDatabaseVersion4Drivers.java

@@ -33,7 +33,7 @@ public enum EDatabaseVersion4Drivers {
     ACCESS_2007(new DbVersion4Drivers(EDatabaseTypeName.ACCESS, "Access 2007", "Access_2007")), //$NON-NLS-1$ //$NON-NLS-2$
     // oracle
     ORACLE_18(new DbVersion4Drivers(new EDatabaseTypeName[] { EDatabaseTypeName.ORACLEFORSID, EDatabaseTypeName.ORACLESN,
-            EDatabaseTypeName.ORACLE_OCI, EDatabaseTypeName.ORACLE_CUSTOM }, "Oracle 18 and above", "ORACLE_18", "ojdbc8-19.3.0.0.jar")),
+            EDatabaseTypeName.ORACLE_OCI, EDatabaseTypeName.ORACLE_CUSTOM }, "Oracle 18 and above", "ORACLE_18", "ojdbc8-19.19.0.0.jar")),
     ORACLE_12(new DbVersion4Drivers(new EDatabaseTypeName[] { EDatabaseTypeName.ORACLEFORSID, EDatabaseTypeName.ORACLESN,
             EDatabaseTypeName.ORACLE_OCI, EDatabaseTypeName.ORACLE_CUSTOM }, "Oracle 12 (Deprecated)", "ORACLE_12",
             "ojdbc7.jar")),

main/plugins/org.talend.core.runtime/src/main/java/org/talend/core/hadoop/IHadoopDistributionService.java

@@ -16,6 +16,7 @@ import java.util.Map;
 
 import org.talend.core.GlobalServiceRegister;
 import org.talend.core.IService;
+import org.talend.core.model.general.Project;
 import org.talend.core.runtime.hd.IDistributionsManager;
 import org.talend.core.runtime.hd.IDynamicDistributionManager;
 import org.talend.core.runtime.hd.IHDistribution;
@@ -132,6 +133,8 @@ public interface IHadoopDistributionService extends IService {
 
     IDynamicDistributionManager getDynamicDistributionManager();
 
+    void checkAndMigrateDistributionProxyCredential(Project project) throws Exception;
+
     public static IHadoopDistributionService get() {
         GlobalServiceRegister gsr = GlobalServiceRegister.getDefault();
         if (gsr.isServiceRegistered(IHadoopDistributionService.class)) {

main/plugins/org.talend.core.runtime/src/main/java/org/talend/core/hadoop/conf/EHadoopProperties.java

@@ -214,7 +214,9 @@ public enum EHadoopProperties {
     
     UNIV_STANDALONE_EXEC_MEMORY,
     
-    UNIV_STANDALONE_EXEC_CORE;
+    UNIV_STANDALONE_EXEC_CORE,
+    
+    UNIV_SPARK_SUBMIT_SCRIPT_HOME;
 
     public String getName() {
         return this.name();

main/plugins/org.talend.core.runtime/src/main/java/org/talend/core/model/metadata/designerproperties/ComponentToRepositoryProperty.java

@@ -36,6 +36,7 @@ import org.talend.core.model.metadata.IMetadataTable;
 import org.talend.core.model.metadata.MetadataTalendType;
 import org.talend.core.model.metadata.builder.ConvertionHelper;
 import org.talend.core.model.metadata.builder.connection.BRMSConnection;
+import org.talend.core.model.metadata.builder.connection.BigQueryConnection;
 import org.talend.core.model.metadata.builder.connection.Connection;
 import org.talend.core.model.metadata.builder.connection.ConnectionFactory;
 import org.talend.core.model.metadata.builder.connection.DatabaseConnection;
@@ -213,6 +214,8 @@ public class ComponentToRepositoryProperty {
             setFileExcelValue((FileExcelConnection) connection, node, param);
         } else if (connection instanceof SAPConnection) {
             setSAPValue((SAPConnection) connection, node, param);
+        } else if (connection instanceof BigQueryConnection) {
+            setBigQueryValue((BigQueryConnection) connection, node, param);
         } else if (connection instanceof SalesforceSchemaConnection) {
             setSalesforceSchema((SalesforceSchemaConnection) connection, node, param);
         } else if (connection instanceof MDMConnection) {
@@ -1793,6 +1796,30 @@ public class ComponentToRepositoryProperty {
             }
         }
     }
+    
+    private static void setBigQueryValue(BigQueryConnection connection, INode node, IElementParameter param) {
+        if ("SERVICE_ACCOUNT_CREDENTIALS_FILE".equals(param.getRepositoryValue())) {
+            String value = getParameterValue(connection, node, param);
+            if (value != null) {
+                connection.setServiceAccountCredentialsFile(value);
+            }
+        } else if ("PROJECT_ID".equals(param.getRepositoryValue())) {
+            String value = getParameterValue(connection, node, param);
+            if (value != null) {
+                connection.setProjectId(value);
+            }
+        } else if ("USE_REGION_ENDPOINT".equals(param.getRepositoryValue())) {
+            String value = getParameterValue(connection, node, param);
+            if (value != null) {
+                connection.setUseRegionEndpoint(Boolean.valueOf(value));
+            }
+        } else if ("REGION_ENDPOINT_BQ".equals(param.getRepositoryValue())) {
+            String value = getParameterValue(connection, node, param);
+            if (value != null) {
+                connection.setRegionEndpoint(value);
+            }
+        }
+    }
 
     /**
      *

main/plugins/org.talend.core.runtime/src/main/java/org/talend/core/model/metadata/designerproperties/RepositoryToComponentProperty.java

@@ -20,6 +20,7 @@ import java.util.Iterator;
 import java.util.List;
 import java.util.Map;
 import java.util.Set;
+import java.util.stream.Collectors;
 
 import org.apache.commons.lang3.StringUtils;
 import org.eclipse.core.runtime.Path;
@@ -47,6 +48,7 @@ import org.talend.core.model.metadata.MultiSchemasUtil;
 import org.talend.core.model.metadata.builder.ConvertionHelper;
 import org.talend.core.model.metadata.builder.connection.AdditionalConnectionProperty;
 import org.talend.core.model.metadata.builder.connection.BRMSConnection;
+import org.talend.core.model.metadata.builder.connection.BigQueryConnection;
 import org.talend.core.model.metadata.builder.connection.Concept;
 import org.talend.core.model.metadata.builder.connection.ConceptTarget;
 import org.talend.core.model.metadata.builder.connection.Connection;
@@ -148,6 +150,10 @@ public class RepositoryToComponentProperty {
         if (connection instanceof SAPConnection) {
             return getSAPValue((SAPConnection) connection, value);
         }
+        
+        if (connection instanceof BigQueryConnection) {
+            return getBigQueryValue((BigQueryConnection) connection, value, table);
+        }
 
         if (connection instanceof SalesforceSchemaConnection) {
             return getSalesforceSchemaValue((SalesforceSchemaConnection) connection, value, table);
@@ -456,6 +462,62 @@ public class RepositoryToComponentProperty {
         }
         return null;
     }
+    
+    public static Object getBigQueryValue(BigQueryConnection connection, String value, IMetadataTable table) {
+        if ("SERVICE_ACCOUNT_CREDENTIALS_FILE".equals(value)) {
+            if (isContextMode(connection, connection.getServiceAccountCredentialsFile())) {
+                return connection.getServiceAccountCredentialsFile();
+            } else {
+                return TalendQuoteUtils.addQuotes(connection.getServiceAccountCredentialsFile());
+            }
+        } else if ("PROJECT_ID".equals(value)) {
+            if (isContextMode(connection, connection.getProjectId())) {
+                return connection.getProjectId();
+            } else {
+                return TalendQuoteUtils.addQuotes(connection.getProjectId());
+            }
+        } else if ("USE_REGION_ENDPOINT".equals(value)) {
+            return connection.isUseRegionEndpoint();
+        } else if ("REGION_ENDPOINT_BQ".equals(value)) {
+            if (isContextMode(connection, connection.getRegionEndpoint())) {
+                return connection.getRegionEndpoint();
+            } else {
+                return TalendQuoteUtils.addQuotes(connection.getRegionEndpoint());
+            }
+        } else if ("DATASET".equals(value)) {
+            if(table!=null) {
+                Map<String, String> properties = table.getAdditionalProperties();
+                if(properties!=null) {
+                    String dataSet = properties.get("dataSet");
+                    if (isContextMode(connection, dataSet)) {
+                        return dataSet;
+                    } else {
+                        return TalendQuoteUtils.addQuotes(dataSet);
+                    }
+                }
+            }
+        } else if ("QUERY".equals(value)) {
+            if(table!=null) {
+                Map<String, String> properties = table.getAdditionalProperties();
+                if(properties!=null) {
+                    String dataSet = properties.get("dataSet");
+                    String tableName = table.getLabel();
+                    if(dataSet!=null && tableName!=null) {
+                        List<IMetadataColumn> columns = table.getListColumns();
+                        StringBuilder strBuilder = new StringBuilder();
+                        strBuilder.append("SELECT");
+                        if(columns!=null) {
+                            strBuilder.append(columns.stream().map(column -> column.getOriginalDbColumnName()).collect(Collectors.joining(",", " ", " ")));
+                        }
+                        strBuilder.append("FROM ").append(dataSet).append('.').append(tableName);
+                        return TalendQuoteUtils.addQuotes(strBuilder.toString());
+                    }
+                }
+            }
+        }
+        
+        return null;
+    }
 
     /**
      * DOC gcui Comment method "getHL7Value".

main/plugins/org.talend.core.runtime/src/main/java/org/talend/core/model/repository/ERepositoryObjectType.java

@@ -31,6 +31,7 @@ import org.talend.core.IESBService;
 import org.talend.core.PluginChecker;
 import org.talend.core.model.general.Project;
 import org.talend.core.model.properties.BRMSConnectionItem;
+import org.talend.core.model.properties.BigQueryConnectionItem;
 import org.talend.core.model.properties.CSVFileConnectionItem;
 import org.talend.core.model.properties.ConnectionItem;
 import org.talend.core.model.properties.ContextItem;
@@ -360,10 +361,10 @@ public class ERepositoryObjectType extends DynaEnum<ERepositoryObjectType> {
 
     public final static ERepositoryObjectType METADATA_SAP_TABLE = new ERepositoryObjectType("repository.SAPTable", //$NON-NLS-1$
             "METADATA_SAP_TABLE", 104, true, true, new String[] { PROD_DI }, new String[] {}, false);
-
+    
     public final static ERepositoryObjectType METADATA_SAP_CONTENT_EXTRACTOR = new ERepositoryObjectType("repository.SAPTable", //$NON-NLS-1$
             "METADATA_SAP_CONTENT_EXTRACTOR", 105, true, true, new String[] { PROD_DI }, new String[] {}, false);
-
+    
     public final static ERepositoryObjectType METADATA_CON_CALCULATION_VIEW = new ERepositoryObjectType(
             "repository.metadataCalculationView", "METADATA_CON_CALCULATION_VIEW", 106, true, true, new String[] { PROD_DI },
             new String[] {}, false);
@@ -508,6 +509,8 @@ public class ERepositoryObjectType extends DynaEnum<ERepositoryObjectType> {
     public final static ERepositoryObjectType METADATA_FILE_FTP = ERepositoryObjectType.valueOf("METADATA_FILE_FTP");
 
     public final static ERepositoryObjectType METADATA_SAPCONNECTIONS = ERepositoryObjectType.valueOf("METADATA_SAPCONNECTIONS");
+    
+    public final static ERepositoryObjectType METADATA_BIGQUERYCONNECTIONS = ERepositoryObjectType.valueOf("METADATA_BIGQUERYCONNECTIONS");
 
     public final static ERepositoryObjectType METADATA_FILE_EBCDIC = ERepositoryObjectType.valueOf("METADATA_FILE_EBCDIC");
 
@@ -868,6 +871,8 @@ public class ERepositoryObjectType extends DynaEnum<ERepositoryObjectType> {
             return "DB connection"; //$NON-NLS-1$
         } else if (type == METADATA_SAPCONNECTIONS) {
             return "SAPconnection"; //$NON-NLS-1$
+        } else if (type == METADATA_BIGQUERYCONNECTIONS) {
+            return "BigQueryconnection"; //$NON-NLS-1$
         } else if (type == METADATA_FILE_EBCDIC) {
             return "fileEBCDIC"; //$NON-NLS-1$
         } else if (type == METADATA_FILE_HL7) {
@@ -1079,6 +1084,11 @@ public class ERepositoryObjectType extends DynaEnum<ERepositoryObjectType> {
             public Object caseSAPConnectionItem(SAPConnectionItem object) {
                 return METADATA_SAPCONNECTIONS;
             }
+            
+            @Override
+            public Object caseBigQueryConnectionItem(BigQueryConnectionItem object) {
+                return METADATA_BIGQUERYCONNECTIONS;
+            }
 
             @Override
             public Object caseDelimitedFileConnectionItem(DelimitedFileConnectionItem object) {

main/plugins/org.talend.core.runtime/src/main/java/org/talend/core/model/update/RepositoryUpdateManager.java

@@ -770,6 +770,15 @@ public abstract class RepositoryUpdateManager {
                 updateConnectionContextParam((ConnectionItem) item, citem, valueMap);
             }
         }
+        
+        List<IRepositoryViewObject> bigqueryConnList = FACTORY.getAll(ERepositoryObjectType.METADATA_BIGQUERYCONNECTIONS, true);
+        for (IRepositoryViewObject obj : bigqueryConnList) {
+            Item item = obj.getProperty().getItem();
+            if (item instanceof ConnectionItem) {
+                updateConnectionContextParam((ConnectionItem) item, citem, valueMap);
+            }
+        }
+        
         for (String updateType : UpdateRepositoryHelper.getAllHadoopConnectionTypes()) {
             List<IRepositoryViewObject> hadoopConnList = FACTORY
                     .getAll(ERepositoryObjectType.valueOf(ERepositoryObjectType.class, updateType), true);

main/plugins/org.talend.core.runtime/src/main/java/org/talend/core/nexus/TalendLibsServerManager.java

@@ -12,7 +12,9 @@
 // ============================================================================
 package org.talend.core.nexus;
 
+import java.net.URLEncoder;
 import java.util.Date;
+import java.util.Map;
 
 import org.apache.commons.lang.StringUtils;
 import org.talend.commons.exception.ExceptionHandler;
@@ -25,9 +27,9 @@ import org.talend.core.runtime.CoreRuntimePlugin;
 import org.talend.core.runtime.i18n.Messages;
 import org.talend.core.runtime.projectsetting.ProjectPreferenceManager;
 import org.talend.core.service.IRemoteService;
+import org.talend.core.utils.SecurityStorageUtil;
 import org.talend.repository.model.IProxyRepositoryFactory;
 import org.talend.repository.model.RepositoryConstants;
-import org.talend.utils.security.StudioEncryption;
 
 /**
  * created by wchen on 2015年6月16日 Detailled comment
@@ -81,6 +83,8 @@ public class TalendLibsServerManager {
 
     public static final String ENABLE_PROXY_SETTING = "nexus.proxy.enable";
 
+    public static final String NEXUS_PROXY_STORAGE_CATEGORY = "org.talend.artifact.proxy.setting";
+
     public static final String TALEND_LIB_USER = "";//$NON-NLS-1$
 
     public static final String TALEND_LIB_PASSWORD = "";//$NON-NLS-1$
@@ -255,10 +259,14 @@ public class TalendLibsServerManager {
             boolean enableProxyFlag = prefManager.getBoolean(TalendLibsServerManager.ENABLE_PROXY_SETTING);
             if (enableProxyFlag) {
                 serverBean.setServer(prefManager.getValue(TalendLibsServerManager.NEXUS_PROXY_URL));
-                serverBean.setUserName(prefManager.getValue(TalendLibsServerManager.NEXUS_PROXY_USERNAME));
-                serverBean.setPassword(StudioEncryption.getStudioEncryption(StudioEncryption.EncryptionKeyName.SYSTEM).decrypt(prefManager.getValue(TalendLibsServerManager.NEXUS_PROXY_PASSWORD)));
                 serverBean.setRepositoryId(prefManager.getValue(TalendLibsServerManager.NEXUS_PROXY_REPOSITORY_ID));
                 serverBean.setType(prefManager.getValue(TalendLibsServerManager.NEXUS_PROXY_TYPE));
+                String[] credentials = getProxyArtifactCredentials(serverBean.getServer(), serverBean.getRepositoryId(),
+                        NEXUS_PROXY_USERNAME, NEXUS_PROXY_PASSWORD);
+                if (credentials != null) {
+                    serverBean.setUserName(credentials[0]);
+                    serverBean.setPassword(credentials[1]);
+                }
             }
         }
         if (StringUtils.isNotEmpty(serverBean.getServer())) {
@@ -267,6 +275,89 @@ public class TalendLibsServerManager {
         return null;
     }
 
+    public String[] getProxyArtifactCredentials(String url, String repositoryId, String usernameKey, String passwordKey) {
+        if (StringUtils.isBlank(url)) {
+            return null;
+        }
+        try {
+            String path = getStoragePath(url, repositoryId);
+            Map<String, String> storageNodePairs = SecurityStorageUtil.getSecurityStorageNodePairs(path);
+            if (storageNodePairs != null) {
+                String username = storageNodePairs.get(usernameKey);
+                String password = storageNodePairs.get(passwordKey);
+                if (username == null && password == null) {
+                    return null;
+                }
+                return new String[] { username, password };
+            }
+        } catch (Exception e) {
+            ExceptionHandler.process(e);
+        }
+        return null;
+    }
+
+    public void saveProxyArtifactCredentials(String url, String repositoryId, String usernameKey, String username,
+            String passwordKey, String password) {
+        if (StringUtils.isBlank(url)) {
+            return;
+        }
+        try {
+            String path = getStoragePath(url, repositoryId);
+            SecurityStorageUtil.saveToSecurityStorage(path, usernameKey, username, false, false);
+            SecurityStorageUtil.saveToSecurityStorage(path, passwordKey, password, true, false);
+            SecurityStorageUtil.flushSecurityStorage();
+        } catch (Exception e) {
+            ExceptionHandler.process(e);
+        }
+    }
+
+    public void saveProxyArtifactCredentialsUserName(String url, String repositoryId, String usernameKey, String username,
+            boolean flush) {
+        if (StringUtils.isBlank(url)) {
+            return;
+        }
+        try {
+            String path = getStoragePath(url, repositoryId);
+            SecurityStorageUtil.saveToSecurityStorage(path, usernameKey, username, false, flush);
+        } catch (Exception e) {
+            ExceptionHandler.process(e);
+        }
+    }
+
+    public void saveProxyArtifactCredentialsPassword(String url, String repositoryId, String passwordKey, String password,
+            boolean flush) {
+        if (StringUtils.isBlank(url)) {
+            return;
+        }
+        try {
+            String path = getStoragePath(url, repositoryId);
+            SecurityStorageUtil.saveToSecurityStorage(path, passwordKey, password, true, flush);
+        } catch (Exception e) {
+            ExceptionHandler.process(e);
+        }
+    }
+
+    public void flushSecurityStorage() {
+        try {
+            SecurityStorageUtil.flushSecurityStorage();
+        } catch (Exception e) {
+            ExceptionHandler.process(e);
+        }
+    }
+
+    private String getStoragePath(String url, String repositoryId) throws Exception {
+        String node = url;
+        if (StringUtils.isNotBlank(repositoryId)) {
+            if (!url.endsWith("/")) {
+                node = node + "/";
+            }
+            node = node + repositoryId;
+        }
+        node = URLEncoder.encode(node, "UTF-8");
+        String path = NEXUS_PROXY_STORAGE_CATEGORY + "/" + node;
+        return path;
+    }
+
     public ArtifactRepositoryBean getTalentArtifactServer() {
         ArtifactRepositoryBean serverBean = getProxyArtifactServer();
         if (serverBean == null) {

main/plugins/org.talend.core.runtime/src/main/java/org/talend/core/service/IBigQueryProviderService.java

@@ -0,0 +1,31 @@
+// ============================================================================
+//
+// Copyright (C) 2006-2023 Talend Inc. - www.talend.com
+//
+// This source code is available under agreement available at
+// %InstallDIR%\features\org.talend.rcp.branding.%PRODUCTNAME%\%PRODUCTNAME%license.txt
+//
+// You should have received a copy of the agreement
+// along with this program; if not, write to Talend SA
+// 9 rue Pages 92150 Suresnes, France
+//
+// ============================================================================
+package org.talend.core.service;
+
+import java.util.Map;
+
+import org.talend.core.IProviderService;
+import org.talend.core.model.process.INode;
+import org.talend.core.model.properties.BigQueryConnectionItem;
+import org.talend.repository.model.RepositoryNode;
+
+public interface IBigQueryProviderService extends IProviderService {
+
+    public BigQueryConnectionItem getRepositoryItem(final INode node);
+
+    public boolean isBigQueryNode(final INode node);
+
+    public boolean isBigQueryNode(final RepositoryNode node);
+
+    public boolean isRepositorySchemaLine(INode node, Map<String, Object> lineValue);
+}

main/plugins/org.talend.core.runtime/src/main/java/org/talend/core/service/IStudioLiteP2Service.java

@@ -39,6 +39,8 @@ import org.talend.core.model.update.IStudioUpdateConfig;
  */
 public interface IStudioLiteP2Service extends IService {
 
+    public static final String PROP_CLEARPERSISTEDSTATE = "talend.studio.switchProject.clearPersistedState";
+
     public static final String CONFIG_STORAGE_FOLDER = "talend/studioLite/";
 
     public static final String BUNDLES_INFOS_STORAGE_FOLDER = CONFIG_STORAGE_FOLDER + "bundlesInfo/";

main/plugins/org.talend.core.runtime/src/main/java/org/talend/core/ui/images/RepositoryImageProvider.java

@@ -53,6 +53,8 @@ public class RepositoryImageProvider {
             return ECoreImage.METADATA_CONNECTION_ICON;
         } else if (type == ERepositoryObjectType.METADATA_SAPCONNECTIONS || type == ERepositoryObjectType.METADATA_SAP_FUNCTION) {
             return ECoreImage.METADATA_SAPCONNECTION_ICON;
+        } else if (type == ERepositoryObjectType.METADATA_BIGQUERYCONNECTIONS) {
+            return ECoreImage.METADATA_BIGQUERYCONNECTION_ICON;
         } else if (type == ERepositoryObjectType.SQLPATTERNS) {
             return ECoreImage.METADATA_SQLPATTERN_ICON;
         } else if (type == ERepositoryObjectType.METADATA_CON_TABLE || type == ERepositoryObjectType.METADATA_SAP_IDOC) {

main/plugins/org.talend.core.runtime/src/main/java/org/talend/core/utils/SecurityStorageUtil.java

@@ -0,0 +1,67 @@
+// ============================================================================
+//
+// Copyright (C) 2006-2023 Talend Inc. - www.talend.com
+//
+// This source code is available under agreement available at
+// %InstallDIR%\features\org.talend.rcp.branding.%PRODUCTNAME%\%PRODUCTNAME%license.txt
+//
+// You should have received a copy of the agreement
+// along with this program; if not, write to Talend SA
+// 9 rue Pages 92150 Suresnes, France
+//
+// ============================================================================
+package org.talend.core.utils;
+
+import java.util.HashMap;
+import java.util.Map;
+
+import org.eclipse.equinox.security.storage.ISecurePreferences;
+import org.eclipse.equinox.security.storage.SecurePreferencesFactory;
+
+/**
+ * DOC jding  class global comment. Detailled comment
+ */
+public class SecurityStorageUtil {
+
+    public static void saveToSecurityStorage(String pathName, String key, String value, boolean encrypt) throws Exception {
+        saveToSecurityStorage(pathName, key, value, encrypt, true);
+    }
+
+    public static void saveToSecurityStorage(String pathName, String key, String value, boolean encrypt, boolean flush)
+            throws Exception {
+        ISecurePreferences securePreferences = SecurePreferencesFactory.getDefault();
+        ISecurePreferences node = securePreferences.node(pathName);
+        node.put(key, value, encrypt);
+        if (flush) {
+            securePreferences.flush();
+        }
+    }
+
+    public static void flushSecurityStorage() throws Exception {
+        ISecurePreferences securePreferences = SecurePreferencesFactory.getDefault();
+        securePreferences.flush();
+    }
+
+    public static String getValueFromSecurityStorage(String pathName, String key) throws Exception {
+        ISecurePreferences securePreferences = SecurePreferencesFactory.getDefault();
+        if (!securePreferences.nodeExists(pathName)) {
+            return null;
+        }
+        ISecurePreferences node = securePreferences.node(pathName);
+        return node.get(key, null);
+    }
+
+    public static Map<String, String> getSecurityStorageNodePairs(String pathName) throws Exception {
+        ISecurePreferences securePreferences = SecurePreferencesFactory.getDefault();
+        if (!securePreferences.nodeExists(pathName)) {
+            return null;
+        }
+        Map<String, String> keyValuePair = new HashMap<String, String>();
+        ISecurePreferences node = securePreferences.node(pathName);
+        for (String key : node.keys()) {
+            keyValuePair.put(key, node.get(key, null));
+        }
+        return keyValuePair;
+    }
+
+}

main/plugins/org.talend.core.runtime/src/main/java/org/talend/repository/model/RepositoryNodeUtilities.java

@@ -512,6 +512,7 @@ public class RepositoryNodeUtilities {
                     || curType == ERepositoryObjectType.METADATA_FILE_RULES
                     || curType == ERepositoryObjectType.METADATA_FILE_LINKRULES
                     || curType == ERepositoryObjectType.METADATA_SAPCONNECTIONS
+                    || curType == ERepositoryObjectType.METADATA_BIGQUERYCONNECTIONS
                     || curType == ERepositoryObjectType.METADATA_HEADER_FOOTER) {
                 tmpType = ERepositoryObjectType.METADATA;
             } else if (curType == ERepositoryObjectType.ROUTINES || curType == ERepositoryObjectType.SNIPPETS) {

main/plugins/org.talend.core.runtime/src/main/java/org/talend/repository/ui/properties/StatusHelper.java

@@ -77,6 +77,7 @@ public class StatusHelper {
             case PropertiesPackage.CSV_FILE_CONNECTION_ITEM:
             case PropertiesPackage.DATABASE_CONNECTION_ITEM:
             case PropertiesPackage.SAP_CONNECTION_ITEM:
+            case PropertiesPackage.BIG_QUERY_CONNECTION_ITEM:
             case PropertiesPackage.DELIMITED_FILE_CONNECTION_ITEM:
             case PropertiesPackage.POSITIONAL_FILE_CONNECTION_ITEM:
             case PropertiesPackage.CONTEXT_ITEM:

main/plugins/org.talend.core.ui/src/main/java/org/talend/core/ui/documentation/generation/ExternalNodeComponentHandler.java

@@ -175,9 +175,28 @@ public class ExternalNodeComponentHandler extends AbstractComponentHandler {
                 generateComponentSchemaInfo(externalNode, componentElement);
                 generateComponentElementParamInfo(parametersElement, elementParameterList);
             } else {
+                boolean isSCDComponent = externalNode.getComponent().getName().endsWith("SCD");
+                if (isSCDComponent) {
+                    Element parametersElement = componentElement.addElement("parameters"); //$NON-NLS-1$
+                    List elementParameterList = externalNode.getElementParameters();
+                    generateComponentSchemaInfo(externalNode, componentElement);
+                    generateComponentElementParamInfo(parametersElement, elementParameterList);
+                }
                 URL fileURL = componentDocumentation.getHTMLFile();
                 if (fileURL != null) {
                     this.externalNodeHTMLMap.put(componentName, fileURL);
+                    if (isSCDComponent) {
+                        // add extra check and uncheck icon for SCDComponent
+                        File picPath = new File(
+                                HTMLDocUtils.getTmpFolder() + File.separatorChar + IHTMLDocConstants.PICTUREFOLDERPATH);
+                        if (picPath.exists()) {
+                            for (File f : picPath.listFiles()) {
+                                if (!picFilePathMap.containsKey(f.getName())) {
+                                    picFilePathMap.put(f.getName(), f.getAbsolutePath());
+                                }
+                            }
+                        }
+                    }
                 }
             }
             componentElement.addComment(componentName);

main/plugins/org.talend.core/src/main/java/org/talend/core/model/param/ERepositoryCategoryType.java

@@ -30,6 +30,7 @@ public enum ERepositoryCategoryType {
     DATABASE,
     SAP,
     SAPIDOC,
+    BIGQUERY,
     EBCDIC,
     HL7,
     FTP,

main/plugins/org.talend.cwm.mip.edit/plugin_fr.properties

@@ -553,7 +553,7 @@ _UI_Column_length_feature=Longueur
 _UI_Column_collationName_feature=Nom de l'interclassement
 _UI_Column_characterSetName_feature=Nom du jeu de caract\u00E8res
 _UI_Column_referencedTableType_feature=Type de la table r\u00E9f\u00E9renc\u00E9e
-_UI_Column_optionScopeColumnSet_feature=Scope des options sur le jeu de colonnes
+_UI_Column_optionScopeColumnSet_feature=P\u00E9rim\u00E8tre des options sur le jeu de colonnes
 _UI_Procedure_type_feature=Type
 _UI_Trigger_eventManipulation_feature=Manipulation d'\u00E9v\u00E9nement
 _UI_Trigger_actionCondition_feature=Condition d'action

main/plugins/org.talend.designer.maven.tos/resources/build/plugins/karaf-maven-plugin-4-2-10/pom.xml

@@ -82,7 +82,12 @@
 		<dependency>
 			<groupId>org.codehaus.plexus</groupId>
 			<artifactId>plexus-archiver</artifactId>
-			<version>3.6.0</version>
+			<version>4.8.0</version>
+		</dependency>
+		<dependency>
+			<groupId>org.codehaus.plexus</groupId>
+			<artifactId>plexus-xml</artifactId>
+			<version>4.0.0</version>
 		</dependency>
 		<dependency>
 		    <groupId>org.codehaus.plexus</groupId>

main/plugins/org.talend.designer.maven.tos/resources/build/pom.xml

@@ -133,7 +133,7 @@
 		<dependency>
 			<groupId>org.apache.maven.plugins</groupId>
 			<artifactId>maven-surefire-plugin</artifactId>
-			<version>2.22.1</version>
+			<version>2.22.2</version>
 			<exclusions>
 				<exclusion>
 					<groupId>org.sonatype.plexus</groupId>
@@ -141,6 +141,21 @@
 				</exclusion>
 			</exclusions>
 		</dependency>
+        <dependency>
+            <groupId>org.apache.maven.surefire</groupId>
+            <artifactId>surefire-booter</artifactId>
+            <version>2.22.2</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.maven.surefire</groupId>
+            <artifactId>surefire-api</artifactId>
+            <version>2.22.2</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.maven.surefire</groupId>
+            <artifactId>surefire-junit4</artifactId>
+            <version>2.22.2</version>
+        </dependency>
 		<dependency>
 			<groupId>org.codehaus.plexus</groupId>
 			<artifactId>plexus-cipher</artifactId>

main/plugins/org.talend.designer.maven.tos/resources/tcompv1/pom.xml

@@ -11,7 +11,7 @@
     <packaging>pom</packaging>
 
     <properties>
-        <tcomp.version>1.58.0</tcomp.version>
+        <tcomp.version>1.59.0</tcomp.version>
         <slf4j.version>1.7.34</slf4j.version>
         <reload4j.version>1.2.22</reload4j.version>
     </properties>

main/plugins/org.talend.designer.maven/resources/templates/general/pom_project_template.xml

@@ -44,7 +44,12 @@
 						<dependency>
 							<groupId>org.codehaus.plexus</groupId>
 							<artifactId>plexus-utils</artifactId>
-							<version>3.0.24</version>
+							<version>4.0.0</version>
+						</dependency>
+						<dependency>
+							<groupId>org.codehaus.plexus</groupId>
+							<artifactId>plexus-xml</artifactId>
+							<version>4.0.0</version>
 						</dependency>
 						<dependency>
 							<groupId>commons-io</groupId>
@@ -54,7 +59,7 @@
 						<dependency>
 							<groupId>org.codehaus.plexus</groupId>
 							<artifactId>plexus-archiver</artifactId>
-							<version>3.6.0</version>
+							<version>4.8.0</version>
 						</dependency>
 						<dependency>
 							<groupId>org.apache.maven</groupId>
@@ -123,7 +128,12 @@
 						<dependency>
 							<groupId>org.codehaus.plexus</groupId>
 							<artifactId>plexus-utils</artifactId>
-							<version>3.0.24</version>
+							<version>4.0.0</version>
+						</dependency>
+						<dependency>
+							<groupId>org.codehaus.plexus</groupId>
+							<artifactId>plexus-xml</artifactId>
+							<version>4.0.0</version>
 						</dependency>
 						<dependency>
 							<groupId>org.apache.commons</groupId>
@@ -138,12 +148,12 @@
 						<dependency>
 							<groupId>org.codehaus.plexus</groupId>
 							<artifactId>plexus-archiver</artifactId>
-							<version>3.6.0</version>
+							<version>4.8.0</version>
 						</dependency>
 						<dependency>
 							<groupId>org.codehaus.plexus</groupId>
 							<artifactId>plexus-io</artifactId>
-							<version>3.0.1</version>
+							<version>3.4.1</version>
 						</dependency>
 						<dependency>
 							<groupId>org.apache.maven</groupId>
@@ -165,7 +175,7 @@
 				<plugin>
 					<groupId>org.apache.maven.plugins</groupId>
 					<artifactId>maven-assembly-plugin</artifactId>
-					<version>3.0.0</version>
+					<version>3.6.0</version>
 					<dependencies>
 						<dependency>
 							<groupId>org.apache.maven.shared</groupId>
@@ -175,7 +185,17 @@
 						<dependency>
 							<groupId>org.codehaus.plexus</groupId>
 							<artifactId>plexus-utils</artifactId>
-							<version>3.0.24</version>
+							<version>4.0.0</version>
+						</dependency>
+						<dependency>
+							<groupId>org.codehaus.plexus</groupId>
+							<artifactId>plexus-io</artifactId>
+							<version>3.4.1</version>
+						</dependency>
+						<dependency>
+							<groupId>org.codehaus.plexus</groupId>
+							<artifactId>plexus-xml</artifactId>
+							<version>4.0.0</version>
 						</dependency>
 						<dependency>
 							<groupId>commons-codec</groupId>
@@ -195,7 +215,7 @@
 						<dependency>
 							<groupId>org.codehaus.plexus</groupId>
 							<artifactId>plexus-archiver</artifactId>
-							<version>3.6.0</version>
+							<version>4.8.0</version>
 						</dependency>
 						<dependency>
 							<groupId>org.apache.maven</groupId>
@@ -217,7 +237,7 @@
 				<plugin>
 					<groupId>org.apache.maven.plugins</groupId>
 					<artifactId>maven-surefire-plugin</artifactId>
-					<version>2.22.1</version>
+					<version>2.22.2</version>
 					<dependencies>
 						<dependency>
 							<groupId>org.sonatype.plexus</groupId>

main/plugins/org.talend.librariesmanager/src/main/java/org/talend/librariesmanager/model/ModulesNeededProvider.java

@@ -797,8 +797,6 @@ public class ModulesNeededProvider {
         if (importNeedsListForBeans == null) {
             importNeedsListForBeans = getModulesNeededForRoutes(processItem);
 
-            importNeedsListForBeans.add(getComponentModuleById("CAMEL", "camel-cxf"));
-
             importNeedsListForBeans.add(getComponentModuleById("CAMEL", "cxf-core"));
             importNeedsListForBeans.add(getComponentModuleById("CAMEL", "javax.ws.rs-api"));
             for (ModuleNeeded need : importNeedsListForBeans) {

main/plugins/org.talend.metadata.managment.ui/src/main/java/messages_ja.properties

@@ -142,7 +142,7 @@ DatabaseTableForm.retreiveButtonIsAccessible=[Retrieve] (\u53D6\u5F97)\u30DC\u30
 DatabaseTableForm.retreiveButtonTip=\u30B9\u30AD\u30FC\u30DE\u3092\u5B9A\u7FA9\u3057\u3066\u304F\u3060\u3055\u3044\u3002\u300C\u30B9\u30AD\u30FC\u30DE\u60C5\u5831\u3092\u53D6\u5F97\u300D\u304C\u4F7F\u7528\u3067\u304D\u307E\u3059!
 DatabaseTableForm.retreiveButtonUse=[\u30B9\u30AD\u30FC\u30DE\u3092\u53D6\u5F97]\u30DC\u30BF\u30F3\u3092\u4F7F\u3063\u3066\u3001\u73FE\u5728\u306E\u30B9\u30AD\u30FC\u30DE\u3092\u30C6\u30FC\u30D6\u30EB\u57FA\u672C\u30B9\u30AD\u30FC\u30DE\u306B\u7F6E\u63DB
 DatabaseTableForm.retreiveSchema=\u30B9\u30AD\u30FC\u30DE\u3092\u53D6\u5F97
-DatabaseTableForm.guessSchema=\u30B9\u30AD\u30FC\u30DE\u3092\u63A8\u6E2C
+DatabaseTableForm.guessSchema=\u63A8\u6E2C\u30B9\u30AD\u30FC\u30DE
 DatabaseTableForm.streamDetach=\u30B9\u30C8\u30EA\u30FC\u30E0\u5206\u96E2
 DatabaseTableForm.table=\u30C6\u30FC\u30D6\u30EB\u306B\u57FA\u3065\u3044\u305F
 DatabaseTableForm.tableColumnText.talbe=\u30C6\u30FC\u30D6\u30EB

main/plugins/org.talend.metadata.managment.ui/src/main/java/org/talend/metadata/managment/ui/utils/ExtendedNodeConnectionContextUtils.java

@@ -214,7 +214,10 @@ public class ExtendedNodeConnectionContextUtils {
         StandaloneMaster,
         StandaloneConfigureExecutors,
         StandaloneExecutorMemory,
-        StandaloneExecutorCore
+        StandaloneExecutorCore,
+        
+        //spark submit script
+        SparkSubmitScriptHome
     }
 
     static List<IContextParameter> getContextVariables(final String prefixName, Connection conn, Set<IConnParamName> paramSet) {

main/plugins/org.talend.metadata.managment/src/main/java/org/talend/core/model/metadata/builder/database/ExtractMetaDataUtils.java

@@ -122,7 +122,7 @@ public class ExtractMetaDataUtils {
     private String[] ORACLE_SSL_JARS = new String[] { "oraclepki-12.2.0.1.jar", "osdt_cert-12.2.0.1.jar", //$NON-NLS-1$//$NON-NLS-2$
             "osdt_core-12.2.0.1.jar" }; //$NON-NLS-1$
     
-    private String ORACLE_NLS_JARS = "orai18n-19.3.0.0.jar";
+    private String ORACLE_NLS_JARS = "orai18n-19.19.0.0.jar";
 
     public static final String SNOWFLAKE = "Snowflake"; //$NON-NLS-1$
 

main/plugins/org.talend.model/model/metadata.ecore

@@ -873,6 +873,13 @@
   <eClassifiers xsi:type="ecore:EClass" name="SAPBWTableField" eSuperTypes="#//SAPTableField">
     <eStructuralFeatures xsi:type="ecore:EAttribute" name="logicalName" eType="ecore:EDataType http://www.eclipse.org/emf/2002/Ecore#//EString"/>
   </eClassifiers>
+  <eClassifiers xsi:type="ecore:EClass" name="BigQueryConnection" eSuperTypes="#//Connection">
+    <eStructuralFeatures xsi:type="ecore:EAttribute" name="ServiceAccountCredentialsFile"
+        eType="ecore:EDataType http://www.eclipse.org/emf/2002/Ecore#//EString"/>
+    <eStructuralFeatures xsi:type="ecore:EAttribute" name="ProjectId" eType="ecore:EDataType http://www.eclipse.org/emf/2002/Ecore#//EString"/>
+    <eStructuralFeatures xsi:type="ecore:EAttribute" name="UseRegionEndpoint" eType="ecore:EDataType http://www.eclipse.org/emf/2002/Ecore#//EBoolean"/>
+    <eStructuralFeatures xsi:type="ecore:EAttribute" name="RegionEndpoint" eType="ecore:EDataType http://www.eclipse.org/emf/2002/Ecore#//EString"/>
+  </eClassifiers>
   <eSubpackages name="cwm" nsURI="http://www.talend.org/cwm/2010" nsPrefix="cwm">
     <eSubpackages name="relational" nsURI="http://www.talend.org/cwm/resource/relational/2010"
         nsPrefix="relational">

main/plugins/org.talend.model/model/metadata.genmodel

@@ -574,6 +574,12 @@
     <genClasses ecoreClass="metadata.ecore#//SAPBWTableField">
       <genFeatures createChild="false" ecoreFeature="ecore:EAttribute metadata.ecore#//SAPBWTableField/logicalName"/>
     </genClasses>
+    <genClasses ecoreClass="metadata.ecore#//BigQueryConnection">
+      <genFeatures createChild="false" ecoreFeature="ecore:EAttribute metadata.ecore#//BigQueryConnection/ServiceAccountCredentialsFile"/>
+      <genFeatures createChild="false" ecoreFeature="ecore:EAttribute metadata.ecore#//BigQueryConnection/ProjectId"/>
+      <genFeatures createChild="false" ecoreFeature="ecore:EAttribute metadata.ecore#//BigQueryConnection/UseRegionEndpoint"/>
+      <genFeatures createChild="false" ecoreFeature="ecore:EAttribute metadata.ecore#//BigQueryConnection/RegionEndpoint"/>
+    </genClasses>
     <nestedGenPackages prefix="cwm" basePackage="org.talend" disposableProviderFactory="true"
         ecorePackage="metadata.ecore#//cwm">
       <nestedGenPackages prefix="Relational" basePackage="org.talend.cwm" disposableProviderFactory="true"

main/plugins/org.talend.model/model/properties.ecore

@@ -874,4 +874,5 @@
   <eClassifiers xsi:type="ecore:EClass" name="RoutinesJarItem" eSuperTypes="#//Item">
     <eStructuralFeatures xsi:type="ecore:EReference" name="routinesJarType" eType="#//RoutinesJarType"/>
   </eClassifiers>
+  <eClassifiers xsi:type="ecore:EClass" name="BigQueryConnectionItem" eSuperTypes="#//ConnectionItem"/>
 </ecore:EPackage>

main/plugins/org.talend.model/model/properties.genmodel

@@ -689,5 +689,6 @@
     <genClasses ecoreClass="properties.ecore#//RoutinesJarItem">
       <genFeatures notify="false" createChild="false" propertySortChoices="true" ecoreFeature="ecore:EReference properties.ecore#//RoutinesJarItem/routinesJarType"/>
     </genClasses>
+    <genClasses ecoreClass="properties.ecore#//BigQueryConnectionItem"/>
   </genPackages>
 </genmodel:GenModel>

main/plugins/org.talend.model/src/main/java/org/talend/core/model/metadata/builder/connection/BigQueryAuthMode.java

@@ -0,0 +1,9 @@
+package org.talend.core.model.metadata.builder.connection;
+
+public enum BigQueryAuthMode {
+	
+	SERVICEACCOUNT,
+	OAUTH,
+	TOKEN
+
+}

main/plugins/org.talend.model/src/main/java/org/talend/core/model/metadata/builder/connection/BigQueryConnection.java

@@ -0,0 +1,113 @@
+/**
+ */
+package org.talend.core.model.metadata.builder.connection;
+
+/**
+ * <!-- begin-user-doc -->
+ * A representation of the model object '<em><b>Big Query Connection</b></em>'.
+ * <!-- end-user-doc -->
+ *
+ * <p>
+ * The following features are supported:
+ * </p>
+ * <ul>
+ *   <li>{@link org.talend.core.model.metadata.builder.connection.BigQueryConnection#getServiceAccountCredentialsFile <em>Service Account Credentials File</em>}</li>
+ *   <li>{@link org.talend.core.model.metadata.builder.connection.BigQueryConnection#getProjectId <em>Project Id</em>}</li>
+ *   <li>{@link org.talend.core.model.metadata.builder.connection.BigQueryConnection#isUseRegionEndpoint <em>Use Region Endpoint</em>}</li>
+ *   <li>{@link org.talend.core.model.metadata.builder.connection.BigQueryConnection#getRegionEndpoint <em>Region Endpoint</em>}</li>
+ * </ul>
+ *
+ * @see org.talend.core.model.metadata.builder.connection.ConnectionPackage#getBigQueryConnection()
+ * @model
+ * @generated
+ */
+public interface BigQueryConnection extends Connection {
+	/**
+	 * Returns the value of the '<em><b>Service Account Credentials File</b></em>' attribute.
+	 * <!-- begin-user-doc -->
+	 * <!-- end-user-doc -->
+	 * @return the value of the '<em>Service Account Credentials File</em>' attribute.
+	 * @see #setServiceAccountCredentialsFile(String)
+	 * @see org.talend.core.model.metadata.builder.connection.ConnectionPackage#getBigQueryConnection_ServiceAccountCredentialsFile()
+	 * @model
+	 * @generated
+	 */
+	String getServiceAccountCredentialsFile();
+
+	/**
+	 * Sets the value of the '{@link org.talend.core.model.metadata.builder.connection.BigQueryConnection#getServiceAccountCredentialsFile <em>Service Account Credentials File</em>}' attribute.
+	 * <!-- begin-user-doc -->
+	 * <!-- end-user-doc -->
+	 * @param value the new value of the '<em>Service Account Credentials File</em>' attribute.
+	 * @see #getServiceAccountCredentialsFile()
+	 * @generated
+	 */
+	void setServiceAccountCredentialsFile(String value);
+
+	/**
+	 * Returns the value of the '<em><b>Project Id</b></em>' attribute.
+	 * <!-- begin-user-doc -->
+	 * <!-- end-user-doc -->
+	 * @return the value of the '<em>Project Id</em>' attribute.
+	 * @see #setProjectId(String)
+	 * @see org.talend.core.model.metadata.builder.connection.ConnectionPackage#getBigQueryConnection_ProjectId()
+	 * @model
+	 * @generated
+	 */
+	String getProjectId();
+
+	/**
+	 * Sets the value of the '{@link org.talend.core.model.metadata.builder.connection.BigQueryConnection#getProjectId <em>Project Id</em>}' attribute.
+	 * <!-- begin-user-doc -->
+	 * <!-- end-user-doc -->
+	 * @param value the new value of the '<em>Project Id</em>' attribute.
+	 * @see #getProjectId()
+	 * @generated
+	 */
+	void setProjectId(String value);
+
+	/**
+	 * Returns the value of the '<em><b>Use Region Endpoint</b></em>' attribute.
+	 * <!-- begin-user-doc -->
+	 * <!-- end-user-doc -->
+	 * @return the value of the '<em>Use Region Endpoint</em>' attribute.
+	 * @see #setUseRegionEndpoint(boolean)
+	 * @see org.talend.core.model.metadata.builder.connection.ConnectionPackage#getBigQueryConnection_UseRegionEndpoint()
+	 * @model
+	 * @generated
+	 */
+	boolean isUseRegionEndpoint();
+
+	/**
+	 * Sets the value of the '{@link org.talend.core.model.metadata.builder.connection.BigQueryConnection#isUseRegionEndpoint <em>Use Region Endpoint</em>}' attribute.
+	 * <!-- begin-user-doc -->
+	 * <!-- end-user-doc -->
+	 * @param value the new value of the '<em>Use Region Endpoint</em>' attribute.
+	 * @see #isUseRegionEndpoint()
+	 * @generated
+	 */
+	void setUseRegionEndpoint(boolean value);
+
+	/**
+	 * Returns the value of the '<em><b>Region Endpoint</b></em>' attribute.
+	 * <!-- begin-user-doc -->
+	 * <!-- end-user-doc -->
+	 * @return the value of the '<em>Region Endpoint</em>' attribute.
+	 * @see #setRegionEndpoint(String)
+	 * @see org.talend.core.model.metadata.builder.connection.ConnectionPackage#getBigQueryConnection_RegionEndpoint()
+	 * @model
+	 * @generated
+	 */
+	String getRegionEndpoint();
+
+	/**
+	 * Sets the value of the '{@link org.talend.core.model.metadata.builder.connection.BigQueryConnection#getRegionEndpoint <em>Region Endpoint</em>}' attribute.
+	 * <!-- begin-user-doc -->
+	 * <!-- end-user-doc -->
+	 * @param value the new value of the '<em>Region Endpoint</em>' attribute.
+	 * @see #getRegionEndpoint()
+	 * @generated
+	 */
+	void setRegionEndpoint(String value);
+
+} // BigQueryConnection

main/plugins/org.talend.model/src/main/java/org/talend/core/model/metadata/builder/connection/ConnectionFactory.java

@@ -15,472 +15,481 @@ import org.eclipse.emf.ecore.EFactory;
  */
 public interface ConnectionFactory extends EFactory {
 
-    /**
-     * The singleton instance of the factory.
-     * <!-- begin-user-doc --> <!-- end-user-doc -->
-     * @generated
-     */
-    ConnectionFactory eINSTANCE = org.talend.core.model.metadata.builder.connection.impl.ConnectionFactoryImpl.init();
+	/**
+	 * The singleton instance of the factory.
+	 * <!-- begin-user-doc --> <!-- end-user-doc -->
+	 * @generated
+	 */
+	ConnectionFactory eINSTANCE = org.talend.core.model.metadata.builder.connection.impl.ConnectionFactoryImpl.init();
 
-    /**
-     * Returns a new object of class '<em>Metadata</em>'.
-     * <!-- begin-user-doc --> <!-- end-user-doc -->
-     * @return a new object of class '<em>Metadata</em>'.
-     * @generated
-     */
-    Metadata createMetadata();
+	/**
+	 * Returns a new object of class '<em>Metadata</em>'.
+	 * <!-- begin-user-doc --> <!-- end-user-doc -->
+	 * @return a new object of class '<em>Metadata</em>'.
+	 * @generated
+	 */
+	Metadata createMetadata();
 
-    /**
-     * Returns a new object of class '<em>Connection</em>'.
-     * <!-- begin-user-doc --> <!-- end-user-doc -->
-     * @return a new object of class '<em>Connection</em>'.
-     * @generated
-     */
-    Connection createConnection();
+	/**
+	 * Returns a new object of class '<em>Connection</em>'.
+	 * <!-- begin-user-doc --> <!-- end-user-doc -->
+	 * @return a new object of class '<em>Connection</em>'.
+	 * @generated
+	 */
+	Connection createConnection();
 
-    /**
-     * Returns a new object of class '<em>Metadata Column</em>'.
-     * <!-- begin-user-doc --> <!-- end-user-doc -->
-     * @return a new object of class '<em>Metadata Column</em>'.
-     * @generated
-     */
-    MetadataColumn createMetadataColumn();
+	/**
+	 * Returns a new object of class '<em>Metadata Column</em>'.
+	 * <!-- begin-user-doc --> <!-- end-user-doc -->
+	 * @return a new object of class '<em>Metadata Column</em>'.
+	 * @generated
+	 */
+	MetadataColumn createMetadataColumn();
 
-    /**
-     * Returns a new object of class '<em>Metadata Table</em>'.
-     * <!-- begin-user-doc --> <!-- end-user-doc -->
-     * @return a new object of class '<em>Metadata Table</em>'.
-     * @generated
-     */
-    MetadataTable createMetadataTable();
+	/**
+	 * Returns a new object of class '<em>Metadata Table</em>'.
+	 * <!-- begin-user-doc --> <!-- end-user-doc -->
+	 * @return a new object of class '<em>Metadata Table</em>'.
+	 * @generated
+	 */
+	MetadataTable createMetadataTable();
 
-    /**
-     * Returns a new object of class '<em>Delimited File Connection</em>'.
-     * <!-- begin-user-doc --> <!-- end-user-doc -->
-     * @return a new object of class '<em>Delimited File Connection</em>'.
-     * @generated
-     */
-    DelimitedFileConnection createDelimitedFileConnection();
+	/**
+	 * Returns a new object of class '<em>Delimited File Connection</em>'.
+	 * <!-- begin-user-doc --> <!-- end-user-doc -->
+	 * @return a new object of class '<em>Delimited File Connection</em>'.
+	 * @generated
+	 */
+	DelimitedFileConnection createDelimitedFileConnection();
 
-    /**
-     * Returns a new object of class '<em>Positional File Connection</em>'. <!-- begin-user-doc --> <!-- end-user-doc
-     * -->
-     * 
-     * @return a new object of class '<em>Positional File Connection</em>'.
-     * @generated
-     */
-    PositionalFileConnection createPositionalFileConnection();
+	/**
+	 * Returns a new object of class '<em>Positional File Connection</em>'. <!-- begin-user-doc --> <!-- end-user-doc
+	 * -->
+	 * 
+	 * @return a new object of class '<em>Positional File Connection</em>'.
+	 * @generated
+	 */
+	PositionalFileConnection createPositionalFileConnection();
 
-    /**
-     * Returns a new object of class '<em>Ebcdic Connection</em>'.
-     * <!-- begin-user-doc --> <!-- end-user-doc -->
-     * @return a new object of class '<em>Ebcdic Connection</em>'.
-     * @generated
-     */
-    EbcdicConnection createEbcdicConnection();
+	/**
+	 * Returns a new object of class '<em>Ebcdic Connection</em>'.
+	 * <!-- begin-user-doc --> <!-- end-user-doc -->
+	 * @return a new object of class '<em>Ebcdic Connection</em>'.
+	 * @generated
+	 */
+	EbcdicConnection createEbcdicConnection();
 
-    /**
-     * Returns a new object of class '<em>MDM Connection</em>'.
-     * <!-- begin-user-doc --> <!-- end-user-doc -->
-     * @return a new object of class '<em>MDM Connection</em>'.
-     * @generated
-     */
-    MDMConnection createMDMConnection();
+	/**
+	 * Returns a new object of class '<em>MDM Connection</em>'.
+	 * <!-- begin-user-doc --> <!-- end-user-doc -->
+	 * @return a new object of class '<em>MDM Connection</em>'.
+	 * @generated
+	 */
+	MDMConnection createMDMConnection();
 
-    /**
-     * Returns a new object of class '<em>Database Connection</em>'.
-     * <!-- begin-user-doc --> <!-- end-user-doc -->
-     * @return a new object of class '<em>Database Connection</em>'.
-     * @generated
-     */
-    DatabaseConnection createDatabaseConnection();
+	/**
+	 * Returns a new object of class '<em>Database Connection</em>'.
+	 * <!-- begin-user-doc --> <!-- end-user-doc -->
+	 * @return a new object of class '<em>Database Connection</em>'.
+	 * @generated
+	 */
+	DatabaseConnection createDatabaseConnection();
 
-    /**
-     * Returns a new object of class '<em>SAP Connection</em>'.
-     * <!-- begin-user-doc --> <!-- end-user-doc -->
-     * @return a new object of class '<em>SAP Connection</em>'.
-     * @generated
-     */
-    SAPConnection createSAPConnection();
+	/**
+	 * Returns a new object of class '<em>SAP Connection</em>'.
+	 * <!-- begin-user-doc --> <!-- end-user-doc -->
+	 * @return a new object of class '<em>SAP Connection</em>'.
+	 * @generated
+	 */
+	SAPConnection createSAPConnection();
 
-    /**
-     * Returns a new object of class '<em>SAP Function Unit</em>'.
-     * <!-- begin-user-doc --> <!-- end-user-doc -->
-     * @return a new object of class '<em>SAP Function Unit</em>'.
-     * @generated
-     */
-    SAPFunctionUnit createSAPFunctionUnit();
+	/**
+	 * Returns a new object of class '<em>SAP Function Unit</em>'.
+	 * <!-- begin-user-doc --> <!-- end-user-doc -->
+	 * @return a new object of class '<em>SAP Function Unit</em>'.
+	 * @generated
+	 */
+	SAPFunctionUnit createSAPFunctionUnit();
 
-    /**
-     * Returns a new object of class '<em>SAPI Doc Unit</em>'.
-     * <!-- begin-user-doc --> <!-- end-user-doc -->
-     * @return a new object of class '<em>SAPI Doc Unit</em>'.
-     * @generated
-     */
-    SAPIDocUnit createSAPIDocUnit();
+	/**
+	 * Returns a new object of class '<em>SAPI Doc Unit</em>'.
+	 * <!-- begin-user-doc --> <!-- end-user-doc -->
+	 * @return a new object of class '<em>SAPI Doc Unit</em>'.
+	 * @generated
+	 */
+	SAPIDocUnit createSAPIDocUnit();
 
-    /**
-     * Returns a new object of class '<em>SAP Function Parameter Column</em>'. <!-- begin-user-doc --> <!-- end-user-doc
-     * -->
-     * 
-     * @return a new object of class '<em>SAP Function Parameter Column</em>'.
-     * @generated
-     */
-    SAPFunctionParameterColumn createSAPFunctionParameterColumn();
+	/**
+	 * Returns a new object of class '<em>SAP Function Parameter Column</em>'. <!-- begin-user-doc --> <!-- end-user-doc
+	 * -->
+	 * 
+	 * @return a new object of class '<em>SAP Function Parameter Column</em>'.
+	 * @generated
+	 */
+	SAPFunctionParameterColumn createSAPFunctionParameterColumn();
 
-    /**
-     * Returns a new object of class '<em>SAP Function Parameter Table</em>'. <!-- begin-user-doc --> <!-- end-user-doc
-     * -->
-     * 
-     * @return a new object of class '<em>SAP Function Parameter Table</em>'.
-     * @generated
-     */
-    SAPFunctionParameterTable createSAPFunctionParameterTable();
+	/**
+	 * Returns a new object of class '<em>SAP Function Parameter Table</em>'. <!-- begin-user-doc --> <!-- end-user-doc
+	 * -->
+	 * 
+	 * @return a new object of class '<em>SAP Function Parameter Table</em>'.
+	 * @generated
+	 */
+	SAPFunctionParameterTable createSAPFunctionParameterTable();
 
-    /**
-     * Returns a new object of class '<em>Input SAP Function Parameter Table</em>'.
-     * <!-- begin-user-doc --> <!--
-     * end-user-doc -->
-     * @return a new object of class '<em>Input SAP Function Parameter Table</em>'.
-     * @generated
-     */
-    InputSAPFunctionParameterTable createInputSAPFunctionParameterTable();
+	/**
+	 * Returns a new object of class '<em>Input SAP Function Parameter Table</em>'.
+	 * <!-- begin-user-doc --> <!--
+	 * end-user-doc -->
+	 * @return a new object of class '<em>Input SAP Function Parameter Table</em>'.
+	 * @generated
+	 */
+	InputSAPFunctionParameterTable createInputSAPFunctionParameterTable();
 
-    /**
-     * Returns a new object of class '<em>Output SAP Function Parameter Table</em>'.
-     * <!-- begin-user-doc --> <!--
-     * end-user-doc -->
-     * @return a new object of class '<em>Output SAP Function Parameter Table</em>'.
-     * @generated
-     */
-    OutputSAPFunctionParameterTable createOutputSAPFunctionParameterTable();
+	/**
+	 * Returns a new object of class '<em>Output SAP Function Parameter Table</em>'.
+	 * <!-- begin-user-doc --> <!--
+	 * end-user-doc -->
+	 * @return a new object of class '<em>Output SAP Function Parameter Table</em>'.
+	 * @generated
+	 */
+	OutputSAPFunctionParameterTable createOutputSAPFunctionParameterTable();
 
-    /**
-     * Returns a new object of class '<em>Regexp File Connection</em>'.
-     * <!-- begin-user-doc --> <!-- end-user-doc -->
-     * @return a new object of class '<em>Regexp File Connection</em>'.
-     * @generated
-     */
-    RegexpFileConnection createRegexpFileConnection();
+	/**
+	 * Returns a new object of class '<em>Regexp File Connection</em>'.
+	 * <!-- begin-user-doc --> <!-- end-user-doc -->
+	 * @return a new object of class '<em>Regexp File Connection</em>'.
+	 * @generated
+	 */
+	RegexpFileConnection createRegexpFileConnection();
 
-    /**
-     * Returns a new object of class '<em>Xml File Connection</em>'.
-     * <!-- begin-user-doc --> <!-- end-user-doc -->
-     * @return a new object of class '<em>Xml File Connection</em>'.
-     * @generated
-     */
-    XmlFileConnection createXmlFileConnection();
+	/**
+	 * Returns a new object of class '<em>Xml File Connection</em>'.
+	 * <!-- begin-user-doc --> <!-- end-user-doc -->
+	 * @return a new object of class '<em>Xml File Connection</em>'.
+	 * @generated
+	 */
+	XmlFileConnection createXmlFileConnection();
 
-    /**
-     * Returns a new object of class '<em>Schema Target</em>'.
-     * <!-- begin-user-doc --> <!-- end-user-doc -->
-     * @return a new object of class '<em>Schema Target</em>'.
-     * @generated
-     */
-    SchemaTarget createSchemaTarget();
+	/**
+	 * Returns a new object of class '<em>Schema Target</em>'.
+	 * <!-- begin-user-doc --> <!-- end-user-doc -->
+	 * @return a new object of class '<em>Schema Target</em>'.
+	 * @generated
+	 */
+	SchemaTarget createSchemaTarget();
 
-    /**
-     * Returns a new object of class '<em>Queries Connection</em>'.
-     * <!-- begin-user-doc --> <!-- end-user-doc -->
-     * @return a new object of class '<em>Queries Connection</em>'.
-     * @generated
-     */
-    QueriesConnection createQueriesConnection();
+	/**
+	 * Returns a new object of class '<em>Queries Connection</em>'.
+	 * <!-- begin-user-doc --> <!-- end-user-doc -->
+	 * @return a new object of class '<em>Queries Connection</em>'.
+	 * @generated
+	 */
+	QueriesConnection createQueriesConnection();
 
-    /**
-     * Returns a new object of class '<em>Query</em>'.
-     * <!-- begin-user-doc --> <!-- end-user-doc -->
-     * @return a new object of class '<em>Query</em>'.
-     * @generated
-     */
-    Query createQuery();
+	/**
+	 * Returns a new object of class '<em>Query</em>'.
+	 * <!-- begin-user-doc --> <!-- end-user-doc -->
+	 * @return a new object of class '<em>Query</em>'.
+	 * @generated
+	 */
+	Query createQuery();
 
-    /**
-     * Returns a new object of class '<em>Ldif File Connection</em>'.
-     * <!-- begin-user-doc --> <!-- end-user-doc -->
-     * @return a new object of class '<em>Ldif File Connection</em>'.
-     * @generated
-     */
-    LdifFileConnection createLdifFileConnection();
+	/**
+	 * Returns a new object of class '<em>Ldif File Connection</em>'.
+	 * <!-- begin-user-doc --> <!-- end-user-doc -->
+	 * @return a new object of class '<em>Ldif File Connection</em>'.
+	 * @generated
+	 */
+	LdifFileConnection createLdifFileConnection();
 
-    /**
-     * Returns a new object of class '<em>File Excel Connection</em>'.
-     * <!-- begin-user-doc --> <!-- end-user-doc -->
-     * @return a new object of class '<em>File Excel Connection</em>'.
-     * @generated
-     */
-    FileExcelConnection createFileExcelConnection();
+	/**
+	 * Returns a new object of class '<em>File Excel Connection</em>'.
+	 * <!-- begin-user-doc --> <!-- end-user-doc -->
+	 * @return a new object of class '<em>File Excel Connection</em>'.
+	 * @generated
+	 */
+	FileExcelConnection createFileExcelConnection();
 
-    /**
-     * Returns a new object of class '<em>Xml XPath Loop Descriptor</em>'.
-     * <!-- begin-user-doc --> <!-- end-user-doc -->
-     * @return a new object of class '<em>Xml XPath Loop Descriptor</em>'.
-     * @generated
-     */
-    XmlXPathLoopDescriptor createXmlXPathLoopDescriptor();
+	/**
+	 * Returns a new object of class '<em>Xml XPath Loop Descriptor</em>'.
+	 * <!-- begin-user-doc --> <!-- end-user-doc -->
+	 * @return a new object of class '<em>Xml XPath Loop Descriptor</em>'.
+	 * @generated
+	 */
+	XmlXPathLoopDescriptor createXmlXPathLoopDescriptor();
 
-    /**
-     * Returns a new object of class '<em>Generic Schema Connection</em>'.
-     * <!-- begin-user-doc --> <!-- end-user-doc -->
-     * @return a new object of class '<em>Generic Schema Connection</em>'.
-     * @generated
-     */
-    GenericSchemaConnection createGenericSchemaConnection();
+	/**
+	 * Returns a new object of class '<em>Generic Schema Connection</em>'.
+	 * <!-- begin-user-doc --> <!-- end-user-doc -->
+	 * @return a new object of class '<em>Generic Schema Connection</em>'.
+	 * @generated
+	 */
+	GenericSchemaConnection createGenericSchemaConnection();
 
-    /**
-     * Returns a new object of class '<em>LDAP Schema Connection</em>'.
-     * <!-- begin-user-doc --> <!-- end-user-doc -->
-     * @return a new object of class '<em>LDAP Schema Connection</em>'.
-     * @generated
-     */
-    LDAPSchemaConnection createLDAPSchemaConnection();
+	/**
+	 * Returns a new object of class '<em>LDAP Schema Connection</em>'.
+	 * <!-- begin-user-doc --> <!-- end-user-doc -->
+	 * @return a new object of class '<em>LDAP Schema Connection</em>'.
+	 * @generated
+	 */
+	LDAPSchemaConnection createLDAPSchemaConnection();
 
-    /**
-     * Returns a new object of class '<em>WSDL Schema Connection</em>'.
-     * <!-- begin-user-doc --> <!-- end-user-doc -->
-     * @return a new object of class '<em>WSDL Schema Connection</em>'.
-     * @generated
-     */
-    WSDLSchemaConnection createWSDLSchemaConnection();
+	/**
+	 * Returns a new object of class '<em>WSDL Schema Connection</em>'.
+	 * <!-- begin-user-doc --> <!-- end-user-doc -->
+	 * @return a new object of class '<em>WSDL Schema Connection</em>'.
+	 * @generated
+	 */
+	WSDLSchemaConnection createWSDLSchemaConnection();
 
-    /**
-     * Returns a new object of class '<em>Salesforce Schema Connection</em>'. <!-- begin-user-doc --> <!-- end-user-doc
-     * -->
-     * 
-     * @return a new object of class '<em>Salesforce Schema Connection</em>'.
-     * @generated
-     */
-    SalesforceSchemaConnection createSalesforceSchemaConnection();
+	/**
+	 * Returns a new object of class '<em>Salesforce Schema Connection</em>'. <!-- begin-user-doc --> <!-- end-user-doc
+	 * -->
+	 * 
+	 * @return a new object of class '<em>Salesforce Schema Connection</em>'.
+	 * @generated
+	 */
+	SalesforceSchemaConnection createSalesforceSchemaConnection();
 
-    /**
-     * Returns a new object of class '<em>CDC Connection</em>'.
-     * <!-- begin-user-doc --> <!-- end-user-doc -->
-     * @return a new object of class '<em>CDC Connection</em>'.
-     * @generated
-     */
-    CDCConnection createCDCConnection();
+	/**
+	 * Returns a new object of class '<em>CDC Connection</em>'.
+	 * <!-- begin-user-doc --> <!-- end-user-doc -->
+	 * @return a new object of class '<em>CDC Connection</em>'.
+	 * @generated
+	 */
+	CDCConnection createCDCConnection();
 
-    /**
-     * Returns a new object of class '<em>CDC Type</em>'.
-     * <!-- begin-user-doc --> <!-- end-user-doc -->
-     * @return a new object of class '<em>CDC Type</em>'.
-     * @generated
-     */
-    CDCType createCDCType();
+	/**
+	 * Returns a new object of class '<em>CDC Type</em>'.
+	 * <!-- begin-user-doc --> <!-- end-user-doc -->
+	 * @return a new object of class '<em>CDC Type</em>'.
+	 * @generated
+	 */
+	CDCType createCDCType();
 
-    /**
-     * Returns a new object of class '<em>Subscriber Table</em>'.
-     * <!-- begin-user-doc --> <!-- end-user-doc -->
-     * @return a new object of class '<em>Subscriber Table</em>'.
-     * @generated
-     */
-    SubscriberTable createSubscriberTable();
+	/**
+	 * Returns a new object of class '<em>Subscriber Table</em>'.
+	 * <!-- begin-user-doc --> <!-- end-user-doc -->
+	 * @return a new object of class '<em>Subscriber Table</em>'.
+	 * @generated
+	 */
+	SubscriberTable createSubscriberTable();
 
-    /**
-     * Returns a new object of class '<em>SAP Test Input Parameter Table</em>'.
-     * <!-- begin-user-doc --> <!--
-     * end-user-doc -->
-     * @return a new object of class '<em>SAP Test Input Parameter Table</em>'.
-     * @generated
-     */
-    SAPTestInputParameterTable createSAPTestInputParameterTable();
+	/**
+	 * Returns a new object of class '<em>SAP Test Input Parameter Table</em>'.
+	 * <!-- begin-user-doc --> <!--
+	 * end-user-doc -->
+	 * @return a new object of class '<em>SAP Test Input Parameter Table</em>'.
+	 * @generated
+	 */
+	SAPTestInputParameterTable createSAPTestInputParameterTable();
 
-    /**
-     * Returns a new object of class '<em>Concept</em>'.
-     * <!-- begin-user-doc --> <!-- end-user-doc -->
-     * @return a new object of class '<em>Concept</em>'.
-     * @generated
-     */
-    Concept createConcept();
+	/**
+	 * Returns a new object of class '<em>Concept</em>'.
+	 * <!-- begin-user-doc --> <!-- end-user-doc -->
+	 * @return a new object of class '<em>Concept</em>'.
+	 * @generated
+	 */
+	Concept createConcept();
 
-    /**
-     * Returns a new object of class '<em>Concept Target</em>'.
-     * <!-- begin-user-doc --> <!-- end-user-doc -->
-     * @return a new object of class '<em>Concept Target</em>'.
-     * @generated
-     */
-    ConceptTarget createConceptTarget();
+	/**
+	 * Returns a new object of class '<em>Concept Target</em>'.
+	 * <!-- begin-user-doc --> <!-- end-user-doc -->
+	 * @return a new object of class '<em>Concept Target</em>'.
+	 * @generated
+	 */
+	ConceptTarget createConceptTarget();
 
-    /**
-     * Returns a new object of class '<em>HL7 Connection</em>'.
-     * <!-- begin-user-doc --> <!-- end-user-doc -->
-     * @return a new object of class '<em>HL7 Connection</em>'.
-     * @generated
-     */
-    HL7Connection createHL7Connection();
+	/**
+	 * Returns a new object of class '<em>HL7 Connection</em>'.
+	 * <!-- begin-user-doc --> <!-- end-user-doc -->
+	 * @return a new object of class '<em>HL7 Connection</em>'.
+	 * @generated
+	 */
+	HL7Connection createHL7Connection();
 
-    /**
-     * Returns a new object of class '<em>Header Footer Connection</em>'.
-     * <!-- begin-user-doc --> <!-- end-user-doc -->
-     * @return a new object of class '<em>Header Footer Connection</em>'.
-     * @generated
-     */
-    HeaderFooterConnection createHeaderFooterConnection();
+	/**
+	 * Returns a new object of class '<em>Header Footer Connection</em>'.
+	 * <!-- begin-user-doc --> <!-- end-user-doc -->
+	 * @return a new object of class '<em>Header Footer Connection</em>'.
+	 * @generated
+	 */
+	HeaderFooterConnection createHeaderFooterConnection();
 
-    /**
-     * Returns a new object of class '<em>XML File Node</em>'.
-     * <!-- begin-user-doc --> <!-- end-user-doc -->
-     * @return a new object of class '<em>XML File Node</em>'.
-     * @generated
-     */
-    XMLFileNode createXMLFileNode();
+	/**
+	 * Returns a new object of class '<em>XML File Node</em>'.
+	 * <!-- begin-user-doc --> <!-- end-user-doc -->
+	 * @return a new object of class '<em>XML File Node</em>'.
+	 * @generated
+	 */
+	XMLFileNode createXMLFileNode();
 
-    /**
-     * Returns a new object of class '<em>WSDL Parameter</em>'.
-     * <!-- begin-user-doc --> <!-- end-user-doc -->
-     * @return a new object of class '<em>WSDL Parameter</em>'.
-     * @generated
-     */
-    WSDLParameter createWSDLParameter();
+	/**
+	 * Returns a new object of class '<em>WSDL Parameter</em>'.
+	 * <!-- begin-user-doc --> <!-- end-user-doc -->
+	 * @return a new object of class '<em>WSDL Parameter</em>'.
+	 * @generated
+	 */
+	WSDLParameter createWSDLParameter();
 
-    /**
-     * Returns a new object of class '<em>Generic Package</em>'.
-     * <!-- begin-user-doc --> <!-- end-user-doc -->
-     * @return a new object of class '<em>Generic Package</em>'.
-     * @generated
-     */
-    GenericPackage createGenericPackage();
+	/**
+	 * Returns a new object of class '<em>Generic Package</em>'.
+	 * <!-- begin-user-doc --> <!-- end-user-doc -->
+	 * @return a new object of class '<em>Generic Package</em>'.
+	 * @generated
+	 */
+	GenericPackage createGenericPackage();
 
-    /**
-     * Returns a new object of class '<em>HL7 File Node</em>'.
-     * <!-- begin-user-doc --> <!-- end-user-doc -->
-     * @return a new object of class '<em>HL7 File Node</em>'.
-     * @generated
-     */
-    HL7FileNode createHL7FileNode();
+	/**
+	 * Returns a new object of class '<em>HL7 File Node</em>'.
+	 * <!-- begin-user-doc --> <!-- end-user-doc -->
+	 * @return a new object of class '<em>HL7 File Node</em>'.
+	 * @generated
+	 */
+	HL7FileNode createHL7FileNode();
 
-    /**
-     * Returns a new object of class '<em>FTP Connection</em>'.
-     * <!-- begin-user-doc --> <!-- end-user-doc -->
-     * @return a new object of class '<em>FTP Connection</em>'.
-     * @generated
-     */
-    FTPConnection createFTPConnection();
+	/**
+	 * Returns a new object of class '<em>FTP Connection</em>'.
+	 * <!-- begin-user-doc --> <!-- end-user-doc -->
+	 * @return a new object of class '<em>FTP Connection</em>'.
+	 * @generated
+	 */
+	FTPConnection createFTPConnection();
 
-    /**
-     * Returns a new object of class '<em>BRMS Connection</em>'.
-     * <!-- begin-user-doc --> <!-- end-user-doc -->
-     * @return a new object of class '<em>BRMS Connection</em>'.
-     * @generated
-     */
-    BRMSConnection createBRMSConnection();
+	/**
+	 * Returns a new object of class '<em>BRMS Connection</em>'.
+	 * <!-- begin-user-doc --> <!-- end-user-doc -->
+	 * @return a new object of class '<em>BRMS Connection</em>'.
+	 * @generated
+	 */
+	BRMSConnection createBRMSConnection();
 
-    /**
-     * Returns a new object of class '<em>Condition Type</em>'.
-     * <!-- begin-user-doc --> <!-- end-user-doc -->
-     * @return a new object of class '<em>Condition Type</em>'.
-     * @generated
-     */
-    ConditionType createConditionType();
+	/**
+	 * Returns a new object of class '<em>Condition Type</em>'.
+	 * <!-- begin-user-doc --> <!-- end-user-doc -->
+	 * @return a new object of class '<em>Condition Type</em>'.
+	 * @generated
+	 */
+	ConditionType createConditionType();
 
-    /**
-     * Returns a new object of class '<em>EDIFACT Connection</em>'.
-     * <!-- begin-user-doc --> <!-- end-user-doc -->
-     * @return a new object of class '<em>EDIFACT Connection</em>'.
-     * @generated
-     */
-    EDIFACTConnection createEDIFACTConnection();
+	/**
+	 * Returns a new object of class '<em>EDIFACT Connection</em>'.
+	 * <!-- begin-user-doc --> <!-- end-user-doc -->
+	 * @return a new object of class '<em>EDIFACT Connection</em>'.
+	 * @generated
+	 */
+	EDIFACTConnection createEDIFACTConnection();
 
-    /**
-     * Returns a new object of class '<em>Salesforce Module Unit</em>'.
-     * <!-- begin-user-doc --> <!-- end-user-doc -->
-     * @return a new object of class '<em>Salesforce Module Unit</em>'.
-     * @generated
-     */
-    SalesforceModuleUnit createSalesforceModuleUnit();
+	/**
+	 * Returns a new object of class '<em>Salesforce Module Unit</em>'.
+	 * <!-- begin-user-doc --> <!-- end-user-doc -->
+	 * @return a new object of class '<em>Salesforce Module Unit</em>'.
+	 * @generated
+	 */
+	SalesforceModuleUnit createSalesforceModuleUnit();
 
-    /**
-     * Returns a new object of class '<em>SAP Table Field</em>'.
-     * <!-- begin-user-doc -->
-     * <!-- end-user-doc -->
-     * @return a new object of class '<em>SAP Table Field</em>'.
-     * @generated
-     */
-    SAPTableField createSAPTableField();
+	/**
+	 * Returns a new object of class '<em>SAP Table Field</em>'.
+	 * <!-- begin-user-doc -->
+	 * <!-- end-user-doc -->
+	 * @return a new object of class '<em>SAP Table Field</em>'.
+	 * @generated
+	 */
+	SAPTableField createSAPTableField();
 
-    /**
-     * Returns a new object of class '<em>SAP Function Parameter</em>'.
-     * <!-- begin-user-doc -->
-     * <!-- end-user-doc -->
-     * @return a new object of class '<em>SAP Function Parameter</em>'.
-     * @generated
-     */
-    SAPFunctionParameter createSAPFunctionParameter();
+	/**
+	 * Returns a new object of class '<em>SAP Function Parameter</em>'.
+	 * <!-- begin-user-doc -->
+	 * <!-- end-user-doc -->
+	 * @return a new object of class '<em>SAP Function Parameter</em>'.
+	 * @generated
+	 */
+	SAPFunctionParameter createSAPFunctionParameter();
 
-    /**
-     * Returns a new object of class '<em>SAP Function Param Data</em>'.
-     * <!-- begin-user-doc -->
-     * <!-- end-user-doc -->
-     * @return a new object of class '<em>SAP Function Param Data</em>'.
-     * @generated
-     */
-    SAPFunctionParamData createSAPFunctionParamData();
+	/**
+	 * Returns a new object of class '<em>SAP Function Param Data</em>'.
+	 * <!-- begin-user-doc -->
+	 * <!-- end-user-doc -->
+	 * @return a new object of class '<em>SAP Function Param Data</em>'.
+	 * @generated
+	 */
+	SAPFunctionParamData createSAPFunctionParamData();
 
-    /**
-     * Returns a new object of class '<em>Additional Connection Property</em>'.
-     * <!-- begin-user-doc -->
-     * <!-- end-user-doc -->
-     * @return a new object of class '<em>Additional Connection Property</em>'.
-     * @generated
-     */
-    AdditionalConnectionProperty createAdditionalConnectionProperty();
+	/**
+	 * Returns a new object of class '<em>Additional Connection Property</em>'.
+	 * <!-- begin-user-doc -->
+	 * <!-- end-user-doc -->
+	 * @return a new object of class '<em>Additional Connection Property</em>'.
+	 * @generated
+	 */
+	AdditionalConnectionProperty createAdditionalConnectionProperty();
 
-    /**
-     * Returns a new object of class '<em>SAPBW Table</em>'.
-     * <!-- begin-user-doc -->
-     * <!-- end-user-doc -->
-     * @return a new object of class '<em>SAPBW Table</em>'.
-     * @generated
-     */
-    SAPBWTable createSAPBWTable();
+	/**
+	 * Returns a new object of class '<em>SAPBW Table</em>'.
+	 * <!-- begin-user-doc -->
+	 * <!-- end-user-doc -->
+	 * @return a new object of class '<em>SAPBW Table</em>'.
+	 * @generated
+	 */
+	SAPBWTable createSAPBWTable();
 
-    /**
-     * Returns a new object of class '<em>SAPBW Table Field</em>'.
-     * <!-- begin-user-doc -->
-     * <!-- end-user-doc -->
-     * @return a new object of class '<em>SAPBW Table Field</em>'.
-     * @generated
-     */
-    SAPBWTableField createSAPBWTableField();
+	/**
+	 * Returns a new object of class '<em>SAPBW Table Field</em>'.
+	 * <!-- begin-user-doc -->
+	 * <!-- end-user-doc -->
+	 * @return a new object of class '<em>SAPBW Table Field</em>'.
+	 * @generated
+	 */
+	SAPBWTableField createSAPBWTableField();
 
-    /**
-     * Returns a new object of class '<em>SAP Table</em>'.
-     * <!-- begin-user-doc -->
-     * <!-- end-user-doc -->
-     * @return a new object of class '<em>SAP Table</em>'.
-     * @generated
-     */
-    SAPTable createSAPTable();
+	/**
+	 * Returns a new object of class '<em>Big Query Connection</em>'.
+	 * <!-- begin-user-doc -->
+	 * <!-- end-user-doc -->
+	 * @return a new object of class '<em>Big Query Connection</em>'.
+	 * @generated
+	 */
+	BigQueryConnection createBigQueryConnection();
 
-    /**
-     * Returns a new object of class '<em>EDIFACT Column</em>'.
-     * <!-- begin-user-doc --> <!-- end-user-doc -->
-     * @return a new object of class '<em>EDIFACT Column</em>'.
-     * @generated
-     */
-    EDIFACTColumn createEDIFACTColumn();
+	/**
+	 * Returns a new object of class '<em>SAP Table</em>'.
+	 * <!-- begin-user-doc -->
+	 * <!-- end-user-doc -->
+	 * @return a new object of class '<em>SAP Table</em>'.
+	 * @generated
+	 */
+	SAPTable createSAPTable();
 
-    /**
-     * Returns a new object of class '<em>Validation Rules Connection</em>'. <!-- begin-user-doc --> <!-- end-user-doc
-     * -->
-     * 
-     * @return a new object of class '<em>Validation Rules Connection</em>'.
-     * @generated
-     */
-    ValidationRulesConnection createValidationRulesConnection();
+	/**
+	 * Returns a new object of class '<em>EDIFACT Column</em>'.
+	 * <!-- begin-user-doc --> <!-- end-user-doc -->
+	 * @return a new object of class '<em>EDIFACT Column</em>'.
+	 * @generated
+	 */
+	EDIFACTColumn createEDIFACTColumn();
 
-    /**
-     * Returns the package supported by this factory.
-     * <!-- begin-user-doc --> <!-- end-user-doc -->
-     * @return the package supported by this factory.
-     * @generated
-     */
-    ConnectionPackage getConnectionPackage();
+	/**
+	 * Returns a new object of class '<em>Validation Rules Connection</em>'. <!-- begin-user-doc --> <!-- end-user-doc
+	 * -->
+	 * 
+	 * @return a new object of class '<em>Validation Rules Connection</em>'.
+	 * @generated
+	 */
+	ValidationRulesConnection createValidationRulesConnection();
 
-    /**
-     * copy this MetadataColumn.
-     * 
-     * @return
-     */
-    MetadataColumn copy(MetadataColumn column, String newId);
+	/**
+	 * Returns the package supported by this factory.
+	 * <!-- begin-user-doc --> <!-- end-user-doc -->
+	 * @return the package supported by this factory.
+	 * @generated
+	 */
+	ConnectionPackage getConnectionPackage();
+
+	/**
+	 * copy this MetadataColumn.
+	 * 
+	 * @return
+	 */
+	MetadataColumn copy(MetadataColumn column, String newId);
 } // ConnectionFactory

main/plugins/org.talend.model/src/main/java/org/talend/core/model/metadata/builder/connection/impl/BigQueryConnectionImpl.java

@@ -0,0 +1,333 @@
+/**
+ */
+package org.talend.core.model.metadata.builder.connection.impl;
+
+import org.eclipse.emf.common.notify.Notification;
+
+import org.eclipse.emf.ecore.EClass;
+
+import org.eclipse.emf.ecore.impl.ENotificationImpl;
+
+import org.talend.core.model.metadata.builder.connection.BigQueryConnection;
+import org.talend.core.model.metadata.builder.connection.ConnectionPackage;
+
+/**
+ * <!-- begin-user-doc -->
+ * An implementation of the model object '<em><b>Big Query Connection</b></em>'.
+ * <!-- end-user-doc -->
+ * <p>
+ * The following features are implemented:
+ * </p>
+ * <ul>
+ *   <li>{@link org.talend.core.model.metadata.builder.connection.impl.BigQueryConnectionImpl#getServiceAccountCredentialsFile <em>Service Account Credentials File</em>}</li>
+ *   <li>{@link org.talend.core.model.metadata.builder.connection.impl.BigQueryConnectionImpl#getProjectId <em>Project Id</em>}</li>
+ *   <li>{@link org.talend.core.model.metadata.builder.connection.impl.BigQueryConnectionImpl#isUseRegionEndpoint <em>Use Region Endpoint</em>}</li>
+ *   <li>{@link org.talend.core.model.metadata.builder.connection.impl.BigQueryConnectionImpl#getRegionEndpoint <em>Region Endpoint</em>}</li>
+ * </ul>
+ *
+ * @generated
+ */
+public class BigQueryConnectionImpl extends ConnectionImpl implements BigQueryConnection {
+	/**
+	 * The default value of the '{@link #getServiceAccountCredentialsFile() <em>Service Account Credentials File</em>}' attribute.
+	 * <!-- begin-user-doc -->
+	 * <!-- end-user-doc -->
+	 * @see #getServiceAccountCredentialsFile()
+	 * @generated
+	 * @ordered
+	 */
+	protected static final String SERVICE_ACCOUNT_CREDENTIALS_FILE_EDEFAULT = null;
+
+	/**
+	 * The cached value of the '{@link #getServiceAccountCredentialsFile() <em>Service Account Credentials File</em>}' attribute.
+	 * <!-- begin-user-doc -->
+	 * <!-- end-user-doc -->
+	 * @see #getServiceAccountCredentialsFile()
+	 * @generated
+	 * @ordered
+	 */
+	protected String serviceAccountCredentialsFile = SERVICE_ACCOUNT_CREDENTIALS_FILE_EDEFAULT;
+
+	/**
+	 * The default value of the '{@link #getProjectId() <em>Project Id</em>}' attribute.
+	 * <!-- begin-user-doc -->
+	 * <!-- end-user-doc -->
+	 * @see #getProjectId()
+	 * @generated
+	 * @ordered
+	 */
+	protected static final String PROJECT_ID_EDEFAULT = null;
+
+	/**
+	 * The cached value of the '{@link #getProjectId() <em>Project Id</em>}' attribute.
+	 * <!-- begin-user-doc -->
+	 * <!-- end-user-doc -->
+	 * @see #getProjectId()
+	 * @generated
+	 * @ordered
+	 */
+	protected String projectId = PROJECT_ID_EDEFAULT;
+
+	/**
+	 * The default value of the '{@link #isUseRegionEndpoint() <em>Use Region Endpoint</em>}' attribute.
+	 * <!-- begin-user-doc -->
+	 * <!-- end-user-doc -->
+	 * @see #isUseRegionEndpoint()
+	 * @generated
+	 * @ordered
+	 */
+	protected static final boolean USE_REGION_ENDPOINT_EDEFAULT = false;
+
+	/**
+	 * The cached value of the '{@link #isUseRegionEndpoint() <em>Use Region Endpoint</em>}' attribute.
+	 * <!-- begin-user-doc -->
+	 * <!-- end-user-doc -->
+	 * @see #isUseRegionEndpoint()
+	 * @generated
+	 * @ordered
+	 */
+	protected boolean useRegionEndpoint = USE_REGION_ENDPOINT_EDEFAULT;
+
+	/**
+	 * The default value of the '{@link #getRegionEndpoint() <em>Region Endpoint</em>}' attribute.
+	 * <!-- begin-user-doc -->
+	 * <!-- end-user-doc -->
+	 * @see #getRegionEndpoint()
+	 * @generated
+	 * @ordered
+	 */
+	protected static final String REGION_ENDPOINT_EDEFAULT = null;
+
+	/**
+	 * The cached value of the '{@link #getRegionEndpoint() <em>Region Endpoint</em>}' attribute.
+	 * <!-- begin-user-doc -->
+	 * <!-- end-user-doc -->
+	 * @see #getRegionEndpoint()
+	 * @generated
+	 * @ordered
+	 */
+	protected String regionEndpoint = REGION_ENDPOINT_EDEFAULT;
+
+	/**
+	 * <!-- begin-user-doc -->
+	 * <!-- end-user-doc -->
+	 * @generated
+	 */
+	protected BigQueryConnectionImpl() {
+		super();
+	}
+
+	/**
+	 * <!-- begin-user-doc -->
+	 * <!-- end-user-doc -->
+	 * @generated
+	 */
+	@Override
+	protected EClass eStaticClass() {
+		return ConnectionPackage.Literals.BIG_QUERY_CONNECTION;
+	}
+
+	/**
+	 * <!-- begin-user-doc -->
+	 * <!-- end-user-doc -->
+	 * @generated
+	 */
+	public String getServiceAccountCredentialsFile() {
+		return serviceAccountCredentialsFile;
+	}
+
+	/**
+	 * <!-- begin-user-doc -->
+	 * <!-- end-user-doc -->
+	 * @generated
+	 */
+	public void setServiceAccountCredentialsFile(String newServiceAccountCredentialsFile) {
+		String oldServiceAccountCredentialsFile = serviceAccountCredentialsFile;
+		serviceAccountCredentialsFile = newServiceAccountCredentialsFile;
+		if (eNotificationRequired())
+			eNotify(new ENotificationImpl(this, Notification.SET,
+					ConnectionPackage.BIG_QUERY_CONNECTION__SERVICE_ACCOUNT_CREDENTIALS_FILE,
+					oldServiceAccountCredentialsFile, serviceAccountCredentialsFile));
+	}
+
+	/**
+	 * <!-- begin-user-doc -->
+	 * <!-- end-user-doc -->
+	 * @generated
+	 */
+	public String getProjectId() {
+		return projectId;
+	}
+
+	/**
+	 * <!-- begin-user-doc -->
+	 * <!-- end-user-doc -->
+	 * @generated
+	 */
+	public void setProjectId(String newProjectId) {
+		String oldProjectId = projectId;
+		projectId = newProjectId;
+		if (eNotificationRequired())
+			eNotify(new ENotificationImpl(this, Notification.SET, ConnectionPackage.BIG_QUERY_CONNECTION__PROJECT_ID,
+					oldProjectId, projectId));
+	}
+
+	/**
+	 * <!-- begin-user-doc -->
+	 * <!-- end-user-doc -->
+	 * @generated
+	 */
+	public boolean isUseRegionEndpoint() {
+		return useRegionEndpoint;
+	}
+
+	/**
+	 * <!-- begin-user-doc -->
+	 * <!-- end-user-doc -->
+	 * @generated
+	 */
+	public void setUseRegionEndpoint(boolean newUseRegionEndpoint) {
+		boolean oldUseRegionEndpoint = useRegionEndpoint;
+		useRegionEndpoint = newUseRegionEndpoint;
+		if (eNotificationRequired())
+			eNotify(new ENotificationImpl(this, Notification.SET,
+					ConnectionPackage.BIG_QUERY_CONNECTION__USE_REGION_ENDPOINT, oldUseRegionEndpoint,
+					useRegionEndpoint));
+	}
+
+	/**
+	 * <!-- begin-user-doc -->
+	 * <!-- end-user-doc -->
+	 * @generated
+	 */
+	public String getRegionEndpoint() {
+		return regionEndpoint;
+	}
+
+	/**
+	 * <!-- begin-user-doc -->
+	 * <!-- end-user-doc -->
+	 * @generated
+	 */
+	public void setRegionEndpoint(String newRegionEndpoint) {
+		String oldRegionEndpoint = regionEndpoint;
+		regionEndpoint = newRegionEndpoint;
+		if (eNotificationRequired())
+			eNotify(new ENotificationImpl(this, Notification.SET,
+					ConnectionPackage.BIG_QUERY_CONNECTION__REGION_ENDPOINT, oldRegionEndpoint, regionEndpoint));
+	}
+
+	/**
+	 * <!-- begin-user-doc -->
+	 * <!-- end-user-doc -->
+	 * @generated
+	 */
+	@Override
+	public Object eGet(int featureID, boolean resolve, boolean coreType) {
+		switch (featureID) {
+		case ConnectionPackage.BIG_QUERY_CONNECTION__SERVICE_ACCOUNT_CREDENTIALS_FILE:
+			return getServiceAccountCredentialsFile();
+		case ConnectionPackage.BIG_QUERY_CONNECTION__PROJECT_ID:
+			return getProjectId();
+		case ConnectionPackage.BIG_QUERY_CONNECTION__USE_REGION_ENDPOINT:
+			return isUseRegionEndpoint();
+		case ConnectionPackage.BIG_QUERY_CONNECTION__REGION_ENDPOINT:
+			return getRegionEndpoint();
+		}
+		return super.eGet(featureID, resolve, coreType);
+	}
+
+	/**
+	 * <!-- begin-user-doc -->
+	 * <!-- end-user-doc -->
+	 * @generated
+	 */
+	@Override
+	public void eSet(int featureID, Object newValue) {
+		switch (featureID) {
+		case ConnectionPackage.BIG_QUERY_CONNECTION__SERVICE_ACCOUNT_CREDENTIALS_FILE:
+			setServiceAccountCredentialsFile((String) newValue);
+			return;
+		case ConnectionPackage.BIG_QUERY_CONNECTION__PROJECT_ID:
+			setProjectId((String) newValue);
+			return;
+		case ConnectionPackage.BIG_QUERY_CONNECTION__USE_REGION_ENDPOINT:
+			setUseRegionEndpoint((Boolean) newValue);
+			return;
+		case ConnectionPackage.BIG_QUERY_CONNECTION__REGION_ENDPOINT:
+			setRegionEndpoint((String) newValue);
+			return;
+		}
+		super.eSet(featureID, newValue);
+	}
+
+	/**
+	 * <!-- begin-user-doc -->
+	 * <!-- end-user-doc -->
+	 * @generated
+	 */
+	@Override
+	public void eUnset(int featureID) {
+		switch (featureID) {
+		case ConnectionPackage.BIG_QUERY_CONNECTION__SERVICE_ACCOUNT_CREDENTIALS_FILE:
+			setServiceAccountCredentialsFile(SERVICE_ACCOUNT_CREDENTIALS_FILE_EDEFAULT);
+			return;
+		case ConnectionPackage.BIG_QUERY_CONNECTION__PROJECT_ID:
+			setProjectId(PROJECT_ID_EDEFAULT);
+			return;
+		case ConnectionPackage.BIG_QUERY_CONNECTION__USE_REGION_ENDPOINT:
+			setUseRegionEndpoint(USE_REGION_ENDPOINT_EDEFAULT);
+			return;
+		case ConnectionPackage.BIG_QUERY_CONNECTION__REGION_ENDPOINT:
+			setRegionEndpoint(REGION_ENDPOINT_EDEFAULT);
+			return;
+		}
+		super.eUnset(featureID);
+	}
+
+	/**
+	 * <!-- begin-user-doc -->
+	 * <!-- end-user-doc -->
+	 * @generated
+	 */
+	@Override
+	public boolean eIsSet(int featureID) {
+		switch (featureID) {
+		case ConnectionPackage.BIG_QUERY_CONNECTION__SERVICE_ACCOUNT_CREDENTIALS_FILE:
+			return SERVICE_ACCOUNT_CREDENTIALS_FILE_EDEFAULT == null ? serviceAccountCredentialsFile != null
+					: !SERVICE_ACCOUNT_CREDENTIALS_FILE_EDEFAULT.equals(serviceAccountCredentialsFile);
+		case ConnectionPackage.BIG_QUERY_CONNECTION__PROJECT_ID:
+			return PROJECT_ID_EDEFAULT == null ? projectId != null : !PROJECT_ID_EDEFAULT.equals(projectId);
+		case ConnectionPackage.BIG_QUERY_CONNECTION__USE_REGION_ENDPOINT:
+			return useRegionEndpoint != USE_REGION_ENDPOINT_EDEFAULT;
+		case ConnectionPackage.BIG_QUERY_CONNECTION__REGION_ENDPOINT:
+			return REGION_ENDPOINT_EDEFAULT == null ? regionEndpoint != null
+					: !REGION_ENDPOINT_EDEFAULT.equals(regionEndpoint);
+		}
+		return super.eIsSet(featureID);
+	}
+
+	/**
+	 * <!-- begin-user-doc -->
+	 * <!-- end-user-doc -->
+	 * @generated
+	 */
+	@Override
+	public String toString() {
+		if (eIsProxy())
+			return super.toString();
+
+		StringBuilder result = new StringBuilder(super.toString());
+		result.append(" (ServiceAccountCredentialsFile: ");
+		result.append(serviceAccountCredentialsFile);
+		result.append(", ProjectId: ");
+		result.append(projectId);
+		result.append(", UseRegionEndpoint: ");
+		result.append(useRegionEndpoint);
+		result.append(", RegionEndpoint: ");
+		result.append(regionEndpoint);
+		result.append(')');
+		return result.toString();
+	}
+
+} //BigQueryConnectionImpl

main/plugins/org.talend.model/src/main/java/org/talend/core/model/metadata/builder/connection/validation/BigQueryConnectionValidator.java

@@ -0,0 +1,35 @@
+/**
+ *
+ * $Id$
+ */
+package org.talend.core.model.metadata.builder.connection.validation;
+
+/**
+ * A sample validator interface for {@link org.talend.core.model.metadata.builder.connection.BigQueryConnection}.
+ * This doesn't really do anything, and it's not a real EMF artifact.
+ * It was generated by the org.eclipse.emf.examples.generator.validator plug-in to illustrate how EMF's code generator can be extended.
+ * This can be disabled with -vmargs -Dorg.eclipse.emf.examples.generator.validator=false.
+ */
+public interface BigQueryConnectionValidator {
+	boolean validate();
+
+	boolean validateAccessToken(String value);
+
+	boolean validateServiceAccountCredentialsFile(String value);
+
+	boolean validateClientId(String value);
+
+	boolean validateClientSecret(String value);
+
+	boolean validateAuthorizationCode(String value);
+
+	boolean validateProjectId(String value);
+
+	boolean validateUseRegionEndpoint(boolean value);
+
+	boolean validateRegionEndpoint(String value);
+
+	boolean validateTokenFilePath(String value);
+
+	boolean validateAuthMode(String value);
+}

main/plugins/org.talend.model/src/main/java/org/talend/core/model/properties/BigQueryConnectionItem.java

@@ -0,0 +1,17 @@
+/**
+ */
+package org.talend.core.model.properties;
+
+
+/**
+ * <!-- begin-user-doc -->
+ * A representation of the model object '<em><b>Big Query Connection Item</b></em>'.
+ * <!-- end-user-doc -->
+ *
+ *
+ * @see org.talend.core.model.properties.PropertiesPackage#getBigQueryConnectionItem()
+ * @model
+ * @generated
+ */
+public interface BigQueryConnectionItem extends ConnectionItem {
+} // BigQueryConnectionItem

main/plugins/org.talend.model/src/main/java/org/talend/core/model/properties/impl/BigQueryConnectionItemImpl.java

@@ -0,0 +1,36 @@
+/**
+ */
+package org.talend.core.model.properties.impl;
+
+import org.eclipse.emf.ecore.EClass;
+
+import org.talend.core.model.properties.BigQueryConnectionItem;
+import org.talend.core.model.properties.PropertiesPackage;
+
+/**
+ * <!-- begin-user-doc -->
+ * An implementation of the model object '<em><b>Big Query Connection Item</b></em>'.
+ * <!-- end-user-doc -->
+ *
+ * @generated
+ */
+public class BigQueryConnectionItemImpl extends ConnectionItemImpl implements BigQueryConnectionItem {
+	/**
+	 * <!-- begin-user-doc -->
+	 * <!-- end-user-doc -->
+	 * @generated
+	 */
+	protected BigQueryConnectionItemImpl() {
+		super();
+	}
+
+	/**
+	 * <!-- begin-user-doc -->
+	 * <!-- end-user-doc -->
+	 * @generated
+	 */
+	protected EClass eStaticClass() {
+		return PropertiesPackage.Literals.BIG_QUERY_CONNECTION_ITEM;
+	}
+
+} //BigQueryConnectionItemImpl

main/plugins/org.talend.model/src/main/java/org/talend/core/model/properties/validation/BigQueryConnectionItemValidator.java

@@ -0,0 +1,17 @@
+/**
+ *
+ * $Id$
+ */
+package org.talend.core.model.properties.validation;
+
+
+/**
+ * A sample validator interface for {@link org.talend.core.model.properties.BigQueryConnectionItem}.
+ * This doesn't really do anything, and it's not a real EMF artifact.
+ * It was generated by the org.eclipse.emf.examples.generator.validator plug-in to illustrate how EMF's code generator can be extended.
+ * This can be disabled with -vmargs -Dorg.eclipse.emf.examples.generator.validator=false.
+ */
+public interface BigQueryConnectionItemValidator {
+	boolean validate();
+
+}

main/plugins/org.talend.model/text/description.txt

@@ -1,31 +1,579 @@
-Model component_cache
+Model Metadata
 
 This model description is not a real EMF artifact. It was generated by the
 org.eclipse.emf.examples.generator.validator plug-in to illustrate how EMF's
 code generator can be extended.
 This can be disabled with -vmargs -Dorg.eclipse.emf.examples.generator.validator=false.
 
-Package component_cache <http://www.talend.org/component_cache>
+Package connection <http://www.talend.org/metadata/connection/2010>
 
-  Class ComponentsCache
-    Reference componentEntryMap : ComponentEntryMap<<0..*>>
+  Class Metadata -> AbstractMetadataObject
+    Reference connections : Connection<<0..*>>
 
-  Class ComponentInfo
-    Attribute originalFamilyName : EString
-    Attribute pluginExtension : EString
+  Class Connection -> AbstractMetadataObject, DataProvider
     Attribute version : EString
-    Attribute isTechnical : EBoolean
-    Attribute PluginDependencies : EString<<0..*>>
-    Attribute componentNames : EString<<0..*>>
-    Reference importType : IMPORTType<<0..*>>
-    Attribute isVisibleInComponentDefinition : EBoolean
-    Attribute uriString : EString
-    Attribute pathSource : EString
-    Attribute repositoryType : EString
-    Attribute sourceBundleName : EString
-    Attribute type : EString
-    Attribute providerId : EString
+    Reference queries : QueriesConnection
+    Attribute ContextMode : EBoolean
+    Attribute ContextId : EString
+    Attribute contextName : EString
+    Attribute compProperties : EString
+    Operation getConnectionTypeName() : String
 
-  Class ComponentEntryMap
+  Class MetadataColumn -> AbstractMetadataObject, Field
+    Attribute sourceType : EString
+    Attribute defaultValue : EString
+    Attribute talendType : EString
+    Attribute key : EBoolean
+    Attribute nullable : EBoolean
+    Reference /table : MetadataTable
+    Attribute originalField : EString
+    Attribute pattern : EString
+    Attribute displayField : EString
+    Attribute originalLength : Integer
+    Attribute relatedEntity : EString
+    Attribute relationshipType : EString
+
+  Class AbstractMetadataObject -> ModelElement
+    Attribute properties : Map<<1..1>>
+    Attribute id : EString
+    Attribute comment : EString
+    Attribute label : EString
+    Attribute readOnly : EBoolean
+    Attribute synchronised : EBoolean
+    Attribute divergency : EBoolean
+
+  Class MetadataTable -> AbstractMetadataObject, Class
+    Attribute sourceName : EString
+    Attribute tableType : EString
+    Attribute attachedCDC : EBoolean
+    Attribute activatedCDC : EBoolean
+    Reference /columns : MetadataColumn<<0..*>>
+    Reference connection : Connection
+    Reference additionalProperties : AdditionalProperties<<0..*>>
+
+  Class FileConnection -> Connection
+    Attribute Server : EString<<1..1>>
+    Attribute FilePath : EString<<1..1>>
+    Attribute Format : FileFormat<<1..1>>
+    Attribute Encoding : EString<<1..1>>
+    Attribute FieldSeparatorValue : EString<<1..1>>
+    Attribute RowSeparatorType : RowSeparator<<1..1>>
+    Attribute RowSeparatorValue : EString
+    Attribute TextIdentifier : EString
+    Attribute UseHeader : EBoolean
+    Attribute HeaderValue : EString
+    Attribute UseFooter : EBoolean
+    Attribute FooterValue : EString
+    Attribute UseLimit : EBoolean
+    Attribute LimitValue : EString
+    Attribute FirstLineCaption : EBoolean
+    Attribute RemoveEmptyRow : EBoolean
+    Attribute EscapeType : Escape<<1..1>>
+    Attribute EscapeChar : EString
+    Attribute TextEnclosure : EString
+    Attribute CsvOption : EBoolean
+
+  Class DelimitedFileConnection -> FileConnection
+    Attribute FieldSeparatorType : FieldSeparator<<1..1>>
+    Attribute splitRecord : EBoolean
+
+  Class PositionalFileConnection -> FileConnection
+
+  Class EbcdicConnection -> FileConnection
+    Attribute MidFile : EString
+    Attribute DataFile : EString
+    Attribute CodePage : EString
+    Attribute SourceFileStart : EString
+    Attribute SourceFileEnd : EString
+
+  Class MDMConnection -> Connection
+    Attribute Username : EString
+    Attribute Password : EString
+    Attribute Port : EString
+    Attribute Server : EString
+    Attribute Universe : EString
+    Attribute Datamodel : EString
+    Attribute Datacluster : EString
+    Reference schemas : Concept<<0..*>>
+    Attribute protocol : MDMConnectionProtocol<<1..1>>
+    Attribute context : String<<1..1>>
+    Attribute serverUrl : EString<<1..1>>
+    Operation getConnectionString() : String
+
+  Class DatabaseConnection -> Connection
+    Attribute DatabaseType : EString
+    Attribute DriverJarPath : EString
+    Attribute DriverClass : EString
+    Attribute URL : EString
+    Attribute dbVersionString : EString
+    Attribute Port : EString
+    Attribute Username : EString
+    Attribute Password : EString
+    Attribute ServerName : EString
+    Attribute DatasourceName : EString
+    Attribute FileFieldName : EString
+    Attribute SID : EString
+    Attribute SqlSynthax : EString
+    Attribute StringQuote : EString
+    Attribute NullChar : EString
+    Attribute DbmsId : EString
+    Attribute ProductId : EString
+    Attribute DBRootPath : EString
+    Attribute AdditionalParams : EString
+    Attribute StandardSQL : EBoolean
+    Attribute SystemSQL : EBoolean
+    Reference cdcConns : CDCConnection
+    Attribute cdcTypeMode : EString
+    Attribute SQLMode : EBoolean
+    Attribute UiSchema : EString
+    Reference parameters : AdditionalProperties<<0..*>>
+    Attribute supportNLS : EBoolean
+
+  Class SAPConnection -> Connection
+    Attribute Host : EString
+    Attribute Username : EString
+    Attribute Password : EString
+    Attribute Client : EString
+    Attribute SystemNumber : EString
+    Attribute Language : EString
+    Reference Funtions : SAPFunctionUnit<<0..*>>
+    Attribute currentFucntion : EString
+    Reference IDocs : SAPIDocUnit<<0..*>>
+    Attribute jcoVersion : EString
+    Reference additionalProperties : AdditionalConnectionProperty<<0..*>>
+    Reference BWAdvancedDataStoreObjects : SAPBWTable<<0..*>>
+    Reference BWDataSources : SAPBWTable<<0..*>>
+    Reference BWDataStoreObjects : SAPBWTable<<0..*>>
+    Reference BWInfoCubes : SAPBWTable<<0..*>>
+    Reference BWInfoObjects : SAPBWTable<<0..*>>
+
+  Class SAPFunctionUnit -> AbstractMetadataObject
+    Attribute OutputType : EString
+    Attribute OutputTableName : EString
+    Reference InputParameterTable : InputSAPFunctionParameterTable
+    Reference OutputParameterTable : OutputSAPFunctionParameterTable
+    Reference MetadataTable : MetadataTable
+    Reference connection : SAPConnection
+    Reference tables : MetadataTable<<0..*>>
+    Reference inputTables : MetadataTable<<0..*>>
+    Reference TestInputParameterTable : SAPTestInputParameterTable
+    Reference paramData : SAPFunctionParamData
+    Attribute asXmlSchema : EBoolean
+    Operation setDocument(String) : void
+
+  Class SAPIDocUnit -> AbstractMetadataObject
+    Reference connection : SAPConnection
+    Attribute programId : EString
+    Attribute gatewayService : EString
+    Attribute useXmlOutput : EBoolean
+    Attribute xmlFile : EString
+    Attribute useHtmlOutput : EBoolean
+    Attribute htmlFile : EString
+
+  Class SAPFunctionParameterColumn -> AbstractMetadataObject
+    Attribute ParameterType : EString
+    Attribute StructureOrTableName : EString
+    Attribute DataType : EString
+    Attribute Length : EString
+    Attribute Value : EString
+    Reference ParameterTable : SAPFunctionParameterTable
+    Operation setDescription(String) : void
+
+  Class SAPFunctionParameterTable -> AbstractMetadataObject
+    Reference columns : SAPFunctionParameterColumn<<0..*>>
+
+  Class InputSAPFunctionParameterTable -> SAPFunctionParameterTable
+    Reference functionUnit : SAPFunctionUnit
+
+  Class OutputSAPFunctionParameterTable -> SAPFunctionParameterTable
+    Reference functionUnit : SAPFunctionUnit
+
+  Class RegexpFileConnection -> FileConnection
+    Attribute FieldSeparatorType : FieldSeparator<<1..1>>
+
+  Class XmlFileConnection -> Connection
+    Attribute XsdFilePath : EString
+    Attribute XmlFilePath : EString
+    Attribute Guess : EBoolean
+    Attribute MaskXPattern : EString
+    Reference schema : XmlXPathLoopDescriptor<<0..*>>
+    Attribute Encoding : EString
+    Reference group : XMLFileNode<<0..*>>
+    Reference root : XMLFileNode<<0..*>>
+    Reference loop : XMLFileNode<<0..*>>
+    Attribute inputModel : EBoolean
+    Attribute outputFilePath : EString
+    Attribute fileContent : EByteArray
+    Attribute targetNameSpace : EString
+
+  Class SchemaTarget
+    Attribute RelativeXPathQuery : EString
+    Attribute TagName : EString
+    Reference schema : XmlXPathLoopDescriptor
+
+  Class QueriesConnection
+    Reference connection : Connection
+    Reference query : Query<<0..*>>
+
+  Class Query -> AbstractMetadataObject
+    Attribute value : EString
+    Reference queries : QueriesConnection
+    Attribute contextMode : EBoolean
+
+  Class LdifFileConnection -> Connection
+    Attribute value : EString<<0..*>>
+    Attribute FilePath : EString<<1..1>>
+    Attribute LimitEntry : EInt
+    Attribute UseLimit : EBoolean
+    Attribute Server : EString<<1..1>>
+
+  Class FileExcelConnection -> FileConnection
+    Attribute SheetName : EString<<1..1>>
+    Attribute sheetColumns : EString<<0..*>>
+    Attribute firstColumn : EString
+    Attribute lastColumn : EString
+    Attribute thousandSeparator : EString
+    Attribute decimalSeparator : EString
+    Attribute advancedSpearator : EBoolean
+    Attribute selectAllSheets : EBoolean
+    Attribute sheetList : List
+    Attribute generationMode : EString
+
+  Class XmlXPathLoopDescriptor
+    Attribute LimitBoucle : EIntegerObject
+    Attribute AbsoluteXPathQuery : EString
+    Reference connection : XmlFileConnection
+    Reference schemaTargets : SchemaTarget<<0..*>>
+
+  Class GenericSchemaConnection -> Connection
+    Attribute mappingTypeUsed : EBoolean
+    Attribute mappingTypeId : EString
+
+  Class LDAPSchemaConnection -> Connection
+    Attribute Host : EString
+    Attribute Port : EString
+    Attribute Protocol : EString
+    Attribute Filter : EString
+    Attribute Separator : EString
+    Attribute UseAdvanced : EBoolean
+    Attribute StorePath : EString
+    Attribute UseLimit : EBoolean
+    Attribute UseAuthen : EBoolean
+    Attribute BindPrincipal : EString
+    Attribute BindPassword : EString
+    Attribute LimitValue : EInt
+    Attribute EncryptionMethodName : EString
+    Attribute Value : EString<<0..*>>
+    Attribute SavePassword : EBoolean
+    Attribute Aliases : EString
+    Attribute Referrals : EString
+    Attribute CountLimit : EString
+    Attribute TimeOutLimit : EString
+    Attribute BaseDNs : EString<<0..*>>
+    Attribute GetBaseDNsFromRoot : EBoolean
+    Attribute ReturnAttributes : EString<<0..*>>
+    Attribute SelectedDN : EString
+
+  Class WSDLSchemaConnection -> Connection
+    Attribute WSDL : EString
+    Attribute needAuth : EBoolean
+    Attribute methodName : EString
+    Attribute parameters : List
+    Attribute UserName : EString
+    Attribute Password : EString
+    Attribute useProxy : EBoolean
+    Attribute proxyHost : EString
+    Attribute proxyPort : EString
+    Attribute proxyUser : EString
+    Attribute proxyPassword : EString
+    Attribute Value : EString<<0..*>>
+    Attribute EndpointURI : EString
+    Attribute Encoding : EString
+    Attribute timeOut : EInt
+    Attribute isInputModel : EBoolean
+    Attribute serverNameSpace : EString
+    Attribute serverName : EString
+    Attribute portNameSpace : EString
+    Attribute portName : EString
+    Reference parameterValue : WSDLParameter<<0..*>>
+    Reference outputParameter : WSDLParameter<<0..*>>
+
+  Class SalesforceSchemaConnection -> Connection
+    Attribute webServiceUrl : EString
+    Attribute userName : EString
+    Attribute password : EString
+    Attribute moduleName : EString
+    Attribute queryCondition : EString
+    Attribute useCustomModuleName : EBoolean
+    Attribute useProxy : EBoolean
+    Attribute proxyHost : EString
+    Attribute proxyPort : EString
+    Attribute proxyUsername : EString
+    Attribute proxyPassword : EString
+    Attribute batchSize : EString
+    Attribute useHttpProxy : EBoolean
+    Attribute useAlphbet : EBoolean
+    Attribute timeOut : EString
+    Reference modules : SalesforceModuleUnit<<0..*>>
+    Attribute webServiceUrlTextForOAuth : EString
+    Attribute consumeKey : EString
+    Attribute consumeSecret : EString
+    Attribute callbackHost : EString
+    Attribute callbackPort : EString
+    Attribute salesforceVersion : EString
+    Attribute token : EString
+    Attribute loginType : EString
+
+  Class CDCConnection
+    Reference connection : DatabaseConnection
+    Reference cdcTypes : CDCType<<0..*>>
+
+  Class CDCType -> AbstractMetadataObject
+    Attribute linkDB : EString
+    Reference subscribers : SubscriberTable<<0..*>>
+    Reference cdcConnection : CDCConnection
+    Attribute journalName : EString
+
+  Class SubscriberTable -> TdTable
+    Attribute system : EBoolean
+
+  Class SAPTestInputParameterTable -> SAPFunctionParameterTable
+    Reference functionUnit : SAPFunctionUnit
+
+  Class Concept -> TdTable
+    Attribute LoopExpression : EString
+    Attribute LoopLimit : EIntegerObject
+    Reference conceptTargets : ConceptTarget<<0..*>>
+    Attribute inputModel : EBoolean
+    Reference group : XMLFileNode<<0..*>>
+    Reference root : XMLFileNode<<0..*>>
+    Reference loop : XMLFileNode<<0..*>>
+    Attribute conceptType : MdmConceptType<<1..1>>
+    Attribute xPathPrefix : EString
+
+  Class ConceptTarget
+    Reference schema : Concept
+    Attribute targetName : EString
+    Attribute RelativeLoopExpression : EString
+
+  Class HL7Connection -> FileConnection
+    Attribute StartChar : EString
+    Attribute EndChar : EString
+    Reference root : HL7FileNode<<0..*>>
+    Attribute outputFilePath : EString
+
+  Class HeaderFooterConnection -> Connection
+    Attribute isHeader : EBoolean
+    Attribute imports : EString
+    Attribute mainCode : EString
+    Attribute libraries : EString
+
+  Class XMLFileNode
+    Attribute XMLPath : EString
+    Attribute RelatedColumn : EString
+    Attribute DefaultValue : EString
+    Attribute Attribute : EString
+    Attribute Order : EInt
+    Attribute Type : EString
+
+  Class WSDLParameter
+    Attribute Element : EString
+    Attribute source : EString
+    Attribute Column : EString
+    Attribute Expression : EString
+    Attribute ParameterInfo : EString
+    Attribute ParameterInfoParent : EString
+
+  Class GenericPackage -> Package
+
+  Class HL7FileNode
+    Attribute FilePath : EString
+    Attribute Order : EInt
+    Attribute Attribute : EString
+    Attribute DefaultValue : EString
+    Attribute RelatedColumn : EString
+    Attribute Repeatable : EBoolean
+
+  Class FTPConnection -> Connection
+    Attribute Host : EString
+    Attribute Port : EString
+    Attribute Username : EString
+    Attribute Password : EString
+    Attribute Mode : EString
+    Attribute Ecoding : EString
+    Attribute SFTP : EBoolean
+    Attribute FTPS : EBoolean
+    Attribute Method : EString
+    Attribute Privatekey : EString
+    Attribute Passphrase : EString
+    Attribute KeystoreFile : EString
+    Attribute KeystorePassword : EString
+    Attribute Usesocks : EBoolean
+    Attribute Proxyhost : EString
+    Attribute Proxyport : EString
+    Attribute Proxyuser : EString
+    Attribute Proxypassword : EString
+    Attribute CustomEncode : EString
+    Attribute UseFileNameEncoding : EBoolean
+    Attribute Timeout : EString
+
+  Class BRMSConnection -> Connection
+    Attribute xmlField : EString
+    Attribute urlName : EString
+    Attribute tacWebappName : EString
+    Attribute className : EString
+    Attribute moduleUsed : EString
+    Reference root : XMLFileNode<<0..*>>
+    Reference group : XMLFileNode<<0..*>>
+    Reference loop : XMLFileNode<<0..*>>
+    Attribute package : EString
+
+  Class ValidationRulesConnection -> Connection
+    Attribute isSelect : EBoolean
+    Attribute isInsert : EBoolean
+    Attribute isUpdate : EBoolean
+    Attribute isDelete : EBoolean
+    Attribute type : RuleType
+    Attribute baseSchema : EString
+    Attribute baseColumnNames : EString<<0..*>>
+    Attribute refSchema : EString
+    Attribute refColumnNames : EString<<0..*>>
+    Attribute javaCondition : EString
+    Attribute sqlCondition : EString
+    Attribute logicalOperator : LogicalOperator
+    Reference conditions : ConditionType<<0..*>>
+    Reference innerJoins : InnerJoinMap<<0..*>>
+    Attribute isDisallow : EBoolean
+    Attribute isRejectLink : EBoolean
+
+  Class ConditionType
+    Attribute inputColumn : EString<<1..1>>
+    Attribute function : Function<<1..1>>
+    Attribute operator : Operator<<1..1>>
+    Attribute value : EString
+
+  Class InnerJoinMap
     Attribute key : EString
-    Reference value : ComponentInfo<<0..*>>
+    Attribute value : EString
+
+  Class EDIFACTConnection -> Connection
+    Attribute XmlName : EString
+    Attribute FileName : EString
+    Attribute XmlPath : EString
+
+  Class EDIFACTColumn -> MetadataColumn
+    Attribute EDIColumnName : EString
+    Attribute EDIXpath : EString
+
+  Class SalesforceModuleUnit -> AbstractMetadataObject
+    Reference MetadataTable : MetadataTable
+    Reference connection : SalesforceSchemaConnection
+    Reference tables : MetadataTable<<0..*>>
+    Attribute moduleName : EString
+
+  Class AdditionalProperties
+    Attribute key : EString
+    Attribute value : EString
+
+  Class SAPTable -> MetadataTable
+    Attribute tableSearchType : EString
+
+  Class SAPTableField -> MetadataColumn
+    Attribute businessName : EString
+    Attribute refTable : EString<<0..*>>
+
+  Class SAPFunctionParameter
+    Attribute name : EString
+    Attribute type : EString
+    Attribute description : EString
+    Attribute length : EString
+    Attribute changing : EBoolean
+    Attribute testValue : EString
+    Reference children : SAPFunctionParameter<<0..*>>
+    Attribute tableResideInTables : EBoolean
+
+  Class SAPFunctionParamData
+    Reference inputRoot : SAPFunctionParameter
+    Reference outputRoot : SAPFunctionParameter
+
+  Class AdditionalConnectionProperty
+    Attribute propertyName : EString
+    Attribute Value : EString
+
+  Class SAPBWTable -> SAPTable
+    Attribute modelType : EString
+    Attribute active : EBoolean
+    Attribute sourceSystemName : EString
+    Attribute infoAreaName : EString
+    Attribute innerIOType : EString
+    Attribute category : EString
+
+  Class SAPBWTableField -> SAPTableField
+    Attribute logicalName : EString
+
+  Class BigQueryConnection -> Connection
+    Attribute ServiceAccountCredentialsFile : EString
+    Attribute ProjectId : EString
+    Attribute UseRegionEndpoint : EBoolean
+    Attribute RegionEndpoint : EString
+
+  Enum FileFormat
+    Literal UNIX = 0
+    Literal MAC = 1
+    Literal WINDOWS = 2
+
+  Enum FieldSeparator
+    Literal Tabulation = 0
+    Literal Semicolon = 1
+    Literal Comma = 2
+    Literal Space = 3
+    Literal Alt_65 = 4
+    Literal Custom_ANSI = 5
+    Literal Custom_UTF8 = 6
+    Literal Custom_RegExp = 7
+
+  Enum Escape
+    Literal Delimited = 1
+    Literal CSV = 0
+
+  Enum RowSeparator
+    Literal Custom_String = 0
+    Literal Standart_EOL = 1
+
+  Enum MDMConnectionProtocol
+    Literal HTTP = 0
+
+  Enum MdmConceptType
+    Literal INPUT = 0
+    Literal OUTPUT = 1
+    Literal RECEIVE = 2
+
+  Enum RuleType
+    Literal REFERENCE = 0
+    Literal BASIC = 1
+    Literal CUSTOM = 2
+
+  Enum Function
+    Literal Empty = 0
+    Literal Lower_case = 1
+    Literal Upper_case = 2
+    Literal Lower_case_first = 3
+    Literal Upper_case_first = 4
+    Literal Length = 5
+    Literal Match = 6
+
+  Enum Operator
+    Literal Equals = 0
+    Literal Not_equals = 1
+    Literal Greater = 2
+    Literal Lower = 3
+    Literal Greater_or_equals = 4
+    Literal Lower_or_equals = 5
+
+  Enum LogicalOperator
+    Literal And = 0
+    Literal Or = 1
+
+  DataType Map <java.util.HashMap>
+
+  DataType List <java.util.ArrayList>

main/plugins/org.talend.presentation.onboarding/plugin_fr.properties

@@ -1,2 +1,3 @@
+GuidedTourTalend=Prenez en main le Studio Talend
 Onboarding=Visite guid\u00E9e
-4BasicsWalkthrough=Guide d\u00E9taill\u00E9
+4BasicsWalkthrough=Tutoriel\u00A0: Cr\u00E9ez votre premier Job

main/plugins/org.talend.presentation.onboarding/plugin_ja.properties

@@ -1,2 +1,3 @@
+GuidedTourTalend=Talend Studio\u3092\u4F7F\u3044\u59CB\u3081\u308B
 Onboarding=\u30AC\u30A4\u30C9\u4ED8\u304D\u30C4\u30A2\u30FC
-4BasicsWalkthrough=4\u3064\u306E\u57FA\u672C\u89E3\u8AAC
+4BasicsWalkthrough=\u30C1\u30E5\u30FC\u30C8\u30EA\u30A2\u30EB: \u6700\u521D\u306E\u30B8\u30E7\u30D6\u3092\u4F5C\u6210

main/plugins/org.talend.presentation.onboarding/plugin_zh_CN.properties

@@ -1,2 +1,3 @@
+GuidedTourTalend=\u5F00\u59CB\u4F7F\u7528 Talend Studio
 Onboarding=\u5BFC\u89C8
-4BasicsWalkthrough=4 \u4E2A\u57FA\u672C\u6F14\u7EC3
+4BasicsWalkthrough=\u6559\u7A0B\uFF1A\u521B\u5EFA\u60A8\u7684\u7B2C\u4E00\u4E2A\u4F5C\u4E1A

main/plugins/org.talend.rcp/build.properties

@@ -4,6 +4,9 @@ bin.includes = plugin.xml,\
                content/,\
                icons/,\
                plugin.properties,\
+               plugin_fr.properties,\
+               plugin_ja.properties,\
+               plugin_zh_CN.properties,\
                META-INF/
 source.. = src/main/java/
 bin.excludes = icons/notuse/

main/plugins/org.talend.rcp/src/main/java/org/talend/rcp/intro/Application.java

@@ -301,7 +301,9 @@ public class Application implements IApplication {
                 if (projectType != null) {
                     store.putValue("last_started_project_type", projectType);
                 }
-                System.setProperty("clearPersistedState", Boolean.TRUE.toString());
+                if (!PluginChecker.isStudioLite() || Boolean.getBoolean(IStudioLiteP2Service.PROP_CLEARPERSISTEDSTATE)) {
+                    System.setProperty("clearPersistedState", Boolean.TRUE.toString());
+                }
             }
 
             cleanupNonExistingProjects();

main/plugins/org.talend.repository.localprovider/src/main/java/org/talend/repository/localprovider/model/LocalRepositoryFactory.java

@@ -2588,6 +2588,7 @@ public class LocalRepositoryFactory extends AbstractEMFRepositoryFactory impleme
             case PropertiesPackage.SALESFORCE_SCHEMA_CONNECTION_ITEM:
             case PropertiesPackage.WSDL_SCHEMA_CONNECTION_ITEM:
             case PropertiesPackage.SAP_CONNECTION_ITEM:
+            case PropertiesPackage.BIG_QUERY_CONNECTION_ITEM:
             case PropertiesPackage.MDM_CONNECTION_ITEM:
             case PropertiesPackage.HL7_CONNECTION_ITEM:
             case PropertiesPackage.FTP_CONNECTION_ITEM:
@@ -2950,6 +2951,9 @@ public class LocalRepositoryFactory extends AbstractEMFRepositoryFactory impleme
             case PropertiesPackage.SAP_CONNECTION_ITEM:
                 itemResource = create(project2, (ConnectionItem) item, ERepositoryObjectType.METADATA_SAPCONNECTIONS, path);
                 break;
+            case PropertiesPackage.BIG_QUERY_CONNECTION_ITEM:
+                itemResource = create(project2, (ConnectionItem) item, ERepositoryObjectType.METADATA_BIGQUERYCONNECTIONS, path);
+                break;
             case PropertiesPackage.MDM_CONNECTION_ITEM:
                 itemResource = create(project2, (ConnectionItem) item, ERepositoryObjectType.METADATA_MDMCONNECTION, path);
                 break;

main/plugins/org.talend.repository.metadata/src/main/java/org/talend/repository/metadata/MetadataService.java

@@ -178,6 +178,13 @@ public class MetadataService implements IMetadataService {
                         relatedWizard = service.newWizard(PlatformUI.getWorkbench(), creation, realNode, null);
                     }
                 }
+            } else if (objectType.equals(ERepositoryObjectType.METADATA_BIGQUERYCONNECTIONS)) {
+                if (PluginChecker.isBigQueryWizardPluginLoaded()) {
+                    IProviderService service = GlobalServiceRegister.getDefault().findService("IBigQueryProviderService");
+                    if (service != null) {
+                        relatedWizard = service.newWizard(PlatformUI.getWorkbench(), creation, realNode, null);
+                    }
+                }
             } else if (objectType.equals(ERepositoryObjectType.METADATA_HEADER_FOOTER)) {
                 if (GlobalServiceRegister.getDefault().isServiceRegistered(IHeaderFooterProviderService.class)) {
                     IHeaderFooterProviderService service = (IHeaderFooterProviderService) GlobalServiceRegister.getDefault()

main/plugins/org.talend.repository.metadata/src/main/java/org/talend/repository/metadata/i18n/messages_ja.properties

@@ -1014,7 +1014,7 @@ DatabaseTableForm.refresh.text=\u3053\u306E\u30DC\u30BF\u30F3\u3092\u62BC\u3057\
 DatabaseTableForm.retreiveButtonConfirmation=\u5909\u66F4\u3092\u78BA\u5B9A\u3057\u307E\u3059\u304B?
 DatabaseTableForm.retreiveButtonConfirmationMessage=\u30B9\u30AD\u30FC\u30DE\u8A2D\u5B9A\u304C\u5909\u66F4\u3055\u308C\u3001\u73FE\u5728\u306E\u30B9\u30AD\u30FC\u30DE\u30D7\u30EC\u30D3\u30E5\u30FC\u3068\u306F\u7570\u306A\u308A\u307E\u3059\u3002\u30B9\u30AD\u30FC\u30DE\u3092\u30A2\u30C3\u30D7\u30C7\u30FC\u30C8\u3059\u308B\u3068\u73FE\u5728\u306E\u30B9\u30AD\u30FC\u30DE\u3092\u4E0A\u66F8\u304D\u3057\u307E\u3059\u3002\u7D9A\u3051\u307E\u3059\u304B\uFF1F
 DatabaseTableForm.retreiveButtonIsAccessible=[Retrieve Schema] (\u30B9\u30AD\u30FC\u30DE\u306E\u53D6\u5F97)\u30DC\u30BF\u30F3\u304C\u5229\u7528\u53EF\u80FD\u306B\u306A\u308A\u307E\u3057\u305F\u3002
-DatabaseTableForm.guessSchema=\u30B9\u30AD\u30FC\u30DE\u3092\u63A8\u6E2C
+DatabaseTableForm.guessSchema=\u63A8\u6E2C\u30B9\u30AD\u30FC\u30DE
 DatabaseTableForm.type=\u578B: {0}
 DatabaseTableForm.type_another_name=\u30C7\u30FC\u30BF\u30D9\u30FC\u30B9\u306B\u5B58\u5728\u3059\u308B\u30C6\u30FC\u30D6\u30EB\u540D\u3092\u5165\u529B\u3057\u3066\u304F\u3060\u3055\u3044\u3002
 DatabaseTableForm.typeTable=\u30BF\u30A4\u30D7: TABLE

main/plugins/org.talend.repository.metadata/src/main/java/org/talend/repository/metadata/ui/actions/metadata/AbstractCreateTableAction.java

@@ -17,11 +17,6 @@ import java.util.Collection;
 import java.util.List;
 
 import org.apache.log4j.Logger;
-import org.eclipse.core.runtime.IProgressMonitor;
-import org.eclipse.core.runtime.IStatus;
-import org.eclipse.core.runtime.Status;
-import org.eclipse.core.runtime.jobs.IJobChangeEvent;
-import org.eclipse.core.runtime.jobs.JobChangeAdapter;
 import org.eclipse.emf.common.util.EList;
 import org.eclipse.emf.ecore.util.EcoreUtil;
 import org.eclipse.jface.dialogs.MessageDialog;
@@ -29,7 +24,6 @@ import org.eclipse.jface.wizard.IWizard;
 import org.eclipse.jface.wizard.WizardDialog;
 import org.eclipse.swt.widgets.Display;
 import org.eclipse.ui.PlatformUI;
-import org.eclipse.ui.progress.UIJob;
 import org.talend.commons.exception.LoginException;
 import org.talend.commons.exception.PersistenceException;
 import org.talend.core.GlobalServiceRegister;
@@ -58,6 +52,7 @@ import org.talend.core.model.metadata.builder.database.ExtractMetaDataFromDataBa
 import org.talend.core.model.metadata.builder.database.ExtractMetaDataUtils;
 import org.talend.core.model.metadata.builder.database.JavaSqlFactory;
 import org.talend.core.model.metadata.connection.hive.HiveModeInfo;
+import org.talend.core.model.properties.BigQueryConnectionItem;
 import org.talend.core.model.properties.ConnectionItem;
 import org.talend.core.model.properties.DatabaseConnectionItem;
 import org.talend.core.model.properties.DelimitedFileConnectionItem;
@@ -80,6 +75,7 @@ import org.talend.core.repository.model.ProxyRepositoryFactory;
 import org.talend.core.repository.ui.actions.metadata.AbstractCreateAction;
 import org.talend.core.runtime.CoreRuntimePlugin;
 import org.talend.core.runtime.services.IGenericDBService;
+import org.talend.core.service.IBigQueryProviderService;
 import org.talend.core.service.ISAPProviderService;
 import org.talend.cwm.helper.ConnectionHelper;
 import org.talend.cwm.helper.PackageHelper;
@@ -731,6 +727,37 @@ public abstract class AbstractCreateTableAction extends AbstractCreateAction {
             }
         }
     }
+    
+    public void createBigQuerySchemaWizard(RepositoryNode node, final boolean forceReadOnly) {
+        boolean creation = false;
+        if (node.getType() == ENodeType.REPOSITORY_ELEMENT) {
+            ERepositoryObjectType nodeType = (ERepositoryObjectType) node.getProperties(EProperties.CONTENT_TYPE);
+
+            BigQueryConnectionItem item = null;
+            if (nodeType == ERepositoryObjectType.METADATA_CON_TABLE) {
+                item = (BigQueryConnectionItem) node.getObject().getProperty().getItem();
+                creation = false;
+            } else if (nodeType == ERepositoryObjectType.METADATA_BIGQUERYCONNECTIONS) {
+                item = (BigQueryConnectionItem) node.getObject().getProperty().getItem();
+                creation = true;
+            } else {
+                return;
+            }
+            initContextMode(item);
+
+            IBigQueryProviderService bigqueryService = null;
+            if (GlobalServiceRegister.getDefault().isServiceRegistered(IBigQueryProviderService.class)) {
+            	bigqueryService = GlobalServiceRegister.getDefault().getService(IBigQueryProviderService.class);
+                if (bigqueryService != null) {
+                    IWizard bigqueryWizard = bigqueryService.newWizard(PlatformUI.getWorkbench(), creation, node, getExistingNames());
+                    if (bigqueryWizard != null) {
+                        WizardDialog wizardDialog = new WizardDialog(Display.getCurrent().getActiveShell(), bigqueryWizard);
+                        handleWizard(node, wizardDialog);
+                    }
+                }
+            }
+        }
+    }
 
     /**
      * DOC qzhang Comment method "createWSDLSchemaWizard".

main/plugins/org.talend.repository.metadata/src/main/java/org/talend/repository/metadata/ui/actions/metadata/CreateTableAction.java

@@ -25,6 +25,7 @@ import org.talend.core.model.metadata.builder.connection.DatabaseConnection;
 import org.talend.core.model.metadata.builder.connection.MetadataTable;
 import org.talend.core.model.metadata.builder.connection.SubscriberTable;
 import org.talend.core.model.properties.BRMSConnectionItem;
+import org.talend.core.model.properties.BigQueryConnectionItem;
 import org.talend.core.model.properties.ConnectionItem;
 import org.talend.core.model.properties.DatabaseConnectionItem;
 import org.talend.core.model.properties.EDIFACTConnectionItem;
@@ -169,6 +170,8 @@ public class CreateTableAction extends AbstractCreateTableAction {
         } else if (ERepositoryObjectType.METADATA_SAPCONNECTIONS != null
                 && ERepositoryObjectType.METADATA_SAPCONNECTIONS.equals(nodeType)) {
             createSAPSchemaWizard(node, false);
+        } else if (ERepositoryObjectType.METADATA_BIGQUERYCONNECTIONS.equals(nodeType)) {
+            createBigQuerySchemaWizard(node, false);
         } else {
             createExtenseNodeSchemaWizard(nodeType, node, false);
         }
@@ -225,6 +228,11 @@ public class CreateTableAction extends AbstractCreateTableAction {
                                 }
                             }
                         }
+                        
+                        if (item2 instanceof BigQueryConnectionItem) {
+                            setEnabled(false);
+                            return;
+                        }
 
                         if (item2 instanceof SAPConnectionItem) {
                             setEnabled(false);

main/plugins/org.talend.repository.metadata/src/main/java/org/talend/repository/metadata/ui/actions/metadata/ReadTableAction.java

@@ -20,6 +20,7 @@ import org.talend.core.model.metadata.builder.connection.CDCConnection;
 import org.talend.core.model.metadata.builder.connection.DatabaseConnection;
 import org.talend.core.model.metadata.builder.connection.MetadataTable;
 import org.talend.core.model.properties.BRMSConnectionItem;
+import org.talend.core.model.properties.BigQueryConnectionItem;
 import org.talend.core.model.properties.ConnectionItem;
 import org.talend.core.model.properties.DatabaseConnectionItem;
 import org.talend.core.model.properties.EDIFACTConnectionItem;
@@ -88,6 +89,11 @@ public class ReadTableAction extends AbstractCreateTableAction {
                         setEnabled(false);
                         return;
                     }
+                    
+                    if (item2 instanceof BigQueryConnectionItem) {
+                        setEnabled(false);
+                        return;
+                    }
 
                     if (item2 instanceof HL7ConnectionItem) {
                         setEnabled(false);