| #!/bin/bash |
| # |
| # Licensed 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. See accompanying LICENSE file. |
| # |
| # resolve links - $0 may be a softlink |
| PRG="${0}" |
| |
| [[ `uname -s` == *"CYGWIN"* ]] && CYGWIN=true |
| |
| while [ -h "${PRG}" ]; do |
| ls=`ls -ld "${PRG}"` |
| link=`expr "$ls" : '.*-> \(.*\)$'` |
| if expr "$link" : '/.*' > /dev/null; then |
| PRG="$link" |
| else |
| PRG=`dirname "${PRG}"`/"$link" |
| fi |
| done |
| |
| BASEDIR=`dirname ${PRG}` |
| |
| if test -z "${JAVA_HOME}" |
| then |
| JAVA_BIN=`which java` |
| JAR_BIN=`which jar` |
| else |
| JAVA_BIN="${JAVA_HOME}/bin/java" |
| JAR_BIN="${JAVA_HOME}/bin/jar" |
| fi |
| export JAVA_BIN |
| |
| if [ ! -e "${JAVA_BIN}" ] || [ ! -e "${JAR_BIN}" ]; then |
| echo "$JAVA_BIN and/or $JAR_BIN not found on the system. Please make sure java and jar commands are available." |
| exit 1 |
| fi |
| |
| # Construct ATLAS_CONF where atlas-properties reside |
| # assume the hive-server2 is installed and contains Atlas configuration |
| # Otherwise, need to setup Atlas required properties and libraries before running this tool |
| if [ ! -z "$HIVE_CONF_DIR" ]; then |
| HIVE_CONF=$HIVE_CONF_DIR |
| elif [ ! -z "$HIVE_HOME" ]; then |
| HIVE_CONF="$HIVE_HOME/conf" |
| elif [ -e /etc/hive/conf ]; then |
| HIVE_CONF="/etc/hive/conf" |
| else |
| echo "Could not find a valid HIVE configuration for ATLAS" |
| exit 1 |
| fi |
| if [ -z "$ATLAS_CONF" ]; then |
| export ATLAS_CONF=$HIVE_CONF |
| fi |
| |
| # log dir for applications |
| ATLAS_LOG_DIR="/var/log/atlas" |
| ATLAS_LOG_FILE="impala-bridge.log" |
| LOG_CONFIG="${BASEDIR}/atlas-log4j.xml" |
| |
| # Construct Atlas classpath. |
| DIR=$PWD |
| PARENT="$(dirname "$DIR")" |
| GRANDPARENT="$(dirname "$PARENT")" |
| LIB_PATH="$GRANDPARENT/server/webapp/atlas/WEB-INF/lib" |
| echo "$LIB_PATH" |
| # Construct Atlas classpath. |
| for i in "$LIB_PATH/"*.jar; do |
| ATLASCPPATH="${ATLASCPPATH}:$i" |
| done |
| |
| for i in "${BASEDIR}/"*.jar; do |
| ATLASCPPATH="${ATLASCPPATH}:$i" |
| done |
| |
| if [ -z "${ATLAS_CONF_DIR}" ] && [ -e /etc/atlas/conf ];then |
| ATLAS_CONF_DIR=/etc/atlas/conf |
| fi |
| ATLASCPPATH=${ATLASCPPATH}:${ATLAS_CONF_DIR} |
| |
| if [ -d "${ATLAS_CONF_DIR}" ] && [ -f "${ATLAS_CONF_DIR}/atlas-env.sh" ]; then |
| #source the atlas-env.sh file, use the exported argument into atlas-jvm |
| source ${ATLAS_CONF_DIR}/atlas-env.sh |
| fi |
| |
| echo "Logging: ${ATLAS_LOG_DIR}/${ATLAS_LOG_FILE}" |
| echo "Log config: ${LOG_CONFIG}" |
| |
| TIME=`date %Y%m%d%H%M%s` |
| CP="${ATLASCPPATH}:${ATLAS_CONF}" |
| |
| # If running in cygwin, convert pathnames and classpath to Windows format. |
| if [ "${CYGWIN}" == "true" ] |
| then |
| ATLAS_LOG_DIR=`cygpath -w ${ATLAS_LOG_DIR}` |
| ATLAS_LOG_FILE=`cygpath -w ${ATLAS_LOG_FILE}` |
| CP=`cygpath -w -p ${CP}` |
| fi |
| |
| JAVA_PROPERTIES="$ATLAS_OPTS -Datlas.log.dir=$ATLAS_LOG_DIR -Datlas.log.file=$ATLAS_LOG_FILE -Dlog4j.configuration=file://$LOG_CONFIG" |
| |
| IMPORT_ARGS=$@ |
| JVM_ARGS= |
| |
| JAVA_PROPERTIES="${JAVA_PROPERTIES} ${JVM_ARGS}" |
| "${JAVA_BIN}" ${JAVA_PROPERTIES} -cp "${CP}" org.apache.atlas.impala.ImpalaLineageTool $IMPORT_ARGS |
| |
| RETVAL=$? |
| [ $RETVAL -eq 0 ] && echo Done! |
| [ $RETVAL -ne 0 ] && echo Failed! |
| exit $RETVAL |