11784

Build # 11784

Build Type

push

jenkins

Committed by GitHub

Commit Message

<a href="https://github.com/apache/carbondata/commit/<a class=hub.com/apache/carbondata/commit/8554ecd2eeb6a43b5ab48c300415ab95229653d0">8554ecd2e<a href="https://github.com/apache/carbondata/commit/8554ecd2eeb6a43b5ab48c300415ab95229653d0">">Merge </a><a class="double-link" href="https://github.com/apache/carbondata/commit/<a class="double-link" href="https://github.com/apache/carbondata/commit/045e7d2ef2b6e38153b92ae16e776a4100bfdc44">045e7d2ef</a>">045e7d2ef</a><a href="https://github.com/apache/carbondata/commit/8554ecd2eeb6a43b5ab48c300415ab95229653d0"> into 0a113ce06">0a113ce06</a>

Run Details

64000 of 82709 relevant lines covered (77.38%)

1.01 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

66.67

/core/src/main/java/org/apache/carbondata/core/locks/CarbonLockFactory.java

/*
 * Licensed to the Apache Software Foundation (ASF) under one or more
 * contributor license agreements.  See the NOTICE file distributed with
 * this work for additional information regarding copyright ownership.
 * The ASF licenses this file to You under the Apache License, Version 2.0
 * (the "License"); you may not use this file except in compliance with
 * the License.  You may obtain a copy of the License at
 *
 *    http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

package org.apache.carbondata.core.locks;

import org.apache.carbondata.common.logging.LogServiceFactory;
import org.apache.carbondata.core.constants.CarbonCommonConstants;
import org.apache.carbondata.core.datastore.impl.FileFactory;
import org.apache.carbondata.core.metadata.AbsoluteTableIdentifier;
import org.apache.carbondata.core.util.CarbonProperties;

import org.apache.log4j.Logger;

/**
 * This class is a Lock factory class which is used to provide lock objects.
 * Using this lock object client can request the lock and unlock.
 */
public class CarbonLockFactory {

  /**
   * Attribute for LOGGER
   */
  private static final Logger LOGGER =
      LogServiceFactory.getLogService(CarbonLockFactory.class.getName());
  /**
   * lockTypeConfigured to check if zookeeper feature is enabled or not for carbon.
   */
  private static String lockTypeConfigured;

  private static String lockPath = CarbonProperties.getInstance()
      .getProperty(CarbonCommonConstants.LOCK_PATH, CarbonCommonConstants.LOCK_PATH_DEFAULT)
      .toLowerCase();

  static {
    CarbonLockFactory.getLockTypeConfigured();
  }

  /**
   * This method will determine the lock type.
   *
   * @param absoluteTableIdentifier
   * @param lockFile
   * @return
   */
  public static ICarbonLock getCarbonLockObj(AbsoluteTableIdentifier absoluteTableIdentifier,
      String lockFile) {
    String absoluteLockPath;
    if (lockPath.isEmpty()) {
      absoluteLockPath = absoluteTableIdentifier.getTablePath();
    } else {
      absoluteLockPath =
          getLockpath(absoluteTableIdentifier.getCarbonTableIdentifier().getTableId());
    }
    FileFactory.FileType fileType = FileFactory.getFileType(absoluteLockPath);
    if (lockTypeConfigured.equals(CarbonCommonConstants.CARBON_LOCK_TYPE_ZOOKEEPER)) {
      return new ZooKeeperLocking(absoluteLockPath, lockFile);
    } else if (fileType == FileFactory.FileType.S3) {
      lockTypeConfigured = CarbonCommonConstants.CARBON_LOCK_TYPE_S3;
      return new S3FileLock(absoluteLockPath,
                lockFile);
    } else if (fileType == FileFactory.FileType.HDFS || fileType == FileFactory.FileType.VIEWFS) {
      lockTypeConfigured = CarbonCommonConstants.CARBON_LOCK_TYPE_HDFS;
      return new HdfsFileLock(absoluteLockPath, lockFile);
    } else if (fileType == FileFactory.FileType.ALLUXIO) {
      lockTypeConfigured = CarbonCommonConstants.CARBON_LOCK_TYPE_ALLUXIO;
      return new AlluxioFileLock(absoluteLockPath, lockFile);
    } else {
      lockTypeConfigured = CarbonCommonConstants.CARBON_LOCK_TYPE_LOCAL;
      return new LocalFileLock(absoluteLockPath, lockFile);
    }
  }

  /**
   *
   * @param locFileLocation
   * @param lockFile
   * @return carbon lock
   */
  public static ICarbonLock getSystemLevelCarbonLockObj(String locFileLocation, String lockFile) {
    String lockFileLocation;
    if (lockPath.isEmpty()) {
      lockFileLocation = locFileLocation;
    } else {
      lockFileLocation = getLockpath("1");
    }
    switch (lockTypeConfigured) {
      case CarbonCommonConstants.CARBON_LOCK_TYPE_LOCAL:
        return new LocalFileLock(lockFileLocation, lockFile);
      case CarbonCommonConstants.CARBON_LOCK_TYPE_ZOOKEEPER:
        return new ZooKeeperLocking(lockFileLocation, lockFile);
      case CarbonCommonConstants.CARBON_LOCK_TYPE_HDFS:
        return new HdfsFileLock(lockFileLocation, lockFile);
      case CarbonCommonConstants.CARBON_LOCK_TYPE_S3:
        return new S3FileLock(lockFileLocation, lockFile);
      case CarbonCommonConstants.CARBON_LOCK_TYPE_ALLUXIO:
        return new AlluxioFileLock(lockFileLocation, lockFile);
      default:
        throw new UnsupportedOperationException("Not supported the lock type");
    }
  }

  /**
   * This method will set the zookeeper status whether zookeeper to be used for locking or not.
   */
  private static void getLockTypeConfigured() {
    lockTypeConfigured = CarbonProperties.getInstance()
        .getProperty(CarbonCommonConstants.LOCK_TYPE, CarbonCommonConstants.LOCK_TYPE_DEFAULT)
        .toUpperCase();
    LOGGER.info("Configured lock type is: " + lockTypeConfigured);
  }

  public static String getLockpath(String tableId) {
    return lockPath + CarbonCommonConstants.FILE_SEPARATOR + tableId;
  }

}

1	/*
2	* Licensed to the Apache Software Foundation (ASF) under one or more
3	* contributor license agreements. See the NOTICE file distributed with
4	* this work for additional information regarding copyright ownership.
5	* The ASF licenses this file to You under the Apache License, Version 2.0
6	* (the "License"); you may not use this file except in compliance with
7	* the License. You may obtain a copy of the License at
8	*
9	* http://www.apache.org/licenses/LICENSE-2.0
10	*
11	* Unless required by applicable law or agreed to in writing, software
12	* distributed under the License is distributed on an "AS IS" BASIS,
13	* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14	* See the License for the specific language governing permissions and
15	* limitations under the License.
16	*/
17
18	package org.apache.carbondata.core.locks;
19
20	import org.apache.carbondata.common.logging.LogServiceFactory;
21	import org.apache.carbondata.core.constants.CarbonCommonConstants;
22	import org.apache.carbondata.core.datastore.impl.FileFactory;
23	import org.apache.carbondata.core.metadata.AbsoluteTableIdentifier;
24	import org.apache.carbondata.core.util.CarbonProperties;
25
26	import org.apache.log4j.Logger;
27
28	/**
29	* This class is a Lock factory class which is used to provide lock objects.
30	* Using this lock object client can request the lock and unlock.
31	*/
32	public class CarbonLockFactory {	×
33
34	/**
35	* Attribute for LOGGER
36	*/
37	private static final Logger LOGGER =	1✔
38	LogServiceFactory.getLogService(CarbonLockFactory.class.getName());	1✔
39	/**
40	* lockTypeConfigured to check if zookeeper feature is enabled or not for carbon.
41	*/
42	private static String lockTypeConfigured;
43
44	private static String lockPath = CarbonProperties.getInstance()	1✔
45	.getProperty(CarbonCommonConstants.LOCK_PATH, CarbonCommonConstants.LOCK_PATH_DEFAULT)	1✔
46	.toLowerCase();	1✔
47
48	static {
49	CarbonLockFactory.getLockTypeConfigured();	1✔
50	}	1✔
51
52	/**
53	* This method will determine the lock type.
54	*
55	* @param absoluteTableIdentifier
56	* @param lockFile
57	* @return
58	*/
59	public static ICarbonLock getCarbonLockObj(AbsoluteTableIdentifier absoluteTableIdentifier,
60	String lockFile) {
61	String absoluteLockPath;
62	if (lockPath.isEmpty()) {	1✔
63	absoluteLockPath = absoluteTableIdentifier.getTablePath();	1✔
64	} else {
65	absoluteLockPath =	1✔
66	getLockpath(absoluteTableIdentifier.getCarbonTableIdentifier().getTableId());	1✔
67	}
68	FileFactory.FileType fileType = FileFactory.getFileType(absoluteLockPath);	1✔
69	if (lockTypeConfigured.equals(CarbonCommonConstants.CARBON_LOCK_TYPE_ZOOKEEPER)) {	1✔
70	return new ZooKeeperLocking(absoluteLockPath, lockFile);	×
71	} else if (fileType == FileFactory.FileType.S3) {	1✔
72	lockTypeConfigured = CarbonCommonConstants.CARBON_LOCK_TYPE_S3;	×
73	return new S3FileLock(absoluteLockPath,	×
74	lockFile);
75	} else if (fileType == FileFactory.FileType.HDFS \|\| fileType == FileFactory.FileType.VIEWFS) {	1✔
76	lockTypeConfigured = CarbonCommonConstants.CARBON_LOCK_TYPE_HDFS;	×
77	return new HdfsFileLock(absoluteLockPath, lockFile);	×
78	} else if (fileType == FileFactory.FileType.ALLUXIO) {	1✔
79	lockTypeConfigured = CarbonCommonConstants.CARBON_LOCK_TYPE_ALLUXIO;	×
80	return new AlluxioFileLock(absoluteLockPath, lockFile);	×
81	} else {
82	lockTypeConfigured = CarbonCommonConstants.CARBON_LOCK_TYPE_LOCAL;	1✔
83	return new LocalFileLock(absoluteLockPath, lockFile);	1✔
84	}
85	}
86
87	/**
88	*
89	* @param locFileLocation
90	* @param lockFile
91	* @return carbon lock
92	*/
93	public static ICarbonLock getSystemLevelCarbonLockObj(String locFileLocation, String lockFile) {
94	String lockFileLocation;
95	if (lockPath.isEmpty()) {	1✔
96	lockFileLocation = locFileLocation;	1✔
97	} else {
98	lockFileLocation = getLockpath("1");	×
99	}
100	switch (lockTypeConfigured) {	1✔
101	case CarbonCommonConstants.CARBON_LOCK_TYPE_LOCAL:
102	return new LocalFileLock(lockFileLocation, lockFile);	1✔
103	case CarbonCommonConstants.CARBON_LOCK_TYPE_ZOOKEEPER:
104	return new ZooKeeperLocking(lockFileLocation, lockFile);	×
105	case CarbonCommonConstants.CARBON_LOCK_TYPE_HDFS:
106	return new HdfsFileLock(lockFileLocation, lockFile);	×
107	case CarbonCommonConstants.CARBON_LOCK_TYPE_S3:
108	return new S3FileLock(lockFileLocation, lockFile);	×
109	case CarbonCommonConstants.CARBON_LOCK_TYPE_ALLUXIO:
110	return new AlluxioFileLock(lockFileLocation, lockFile);	×
111	default:
112	throw new UnsupportedOperationException("Not supported the lock type");	×
113	}
114	}
115
116	/**
117	* This method will set the zookeeper status whether zookeeper to be used for locking or not.
118	*/
119	private static void getLockTypeConfigured() {
120	lockTypeConfigured = CarbonProperties.getInstance()	1✔
121	.getProperty(CarbonCommonConstants.LOCK_TYPE, CarbonCommonConstants.LOCK_TYPE_DEFAULT)	1✔
122	.toUpperCase();	1✔
123	LOGGER.info("Configured lock type is: " + lockTypeConfigured);	1✔
124	}	1✔
125
126	public static String getLockpath(String tableId) {
127	return lockPath + CarbonCommonConstants.FILE_SEPARATOR + tableId;	1✔
128	}
129
130	}

apache / carbondata / 11784

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous