Skip to content

Instantly share code, notes, and snippets.

View mesmacosta's full-sized avatar
🏠
Working from home

Marcelo Costa mesmacosta

🏠
Working from home
View GitHub Profile
FROM python:3.7
WORKDIR /app
# Copy the requirements.txt file and install all dependencies.
COPY requirements.txt .
RUN pip install -r requirements.txt
# Downloading and installing gcloud package.
RUN curl https://dl.google.com/dl/cloudsdk/release/google-cloud-sdk.tar.gz > /tmp/google-cloud-sdk.tar.gz
RUN mkdir -p /usr/local/gcloud \
@mesmacosta
mesmacosta / run_coverage.sh
Created September 10, 2019 21:09
Run coverage script
#!/usr/bin/env bash
source ./env/bin/activate
pytest --cov --cov-report html --cov-report term-missing
open /Applications/Google\ Chrome.app htmlcov/index.html
# Login as super user
sudo -s
apt-get install curl
curl -sSL https://get.docker.com/ | sh
╔═════════════════════════════╦════════════════════════════════════════════════════════════════╗
β•‘ Property β•‘ Interface Or Abstract class β•‘
╠═════════════════════════════╬════════════════════════════════════════════════════════════════╗
β•‘ hive.exec.pre.hooks β•‘ org.apache.hadoop.hive.ql.hooks.ExecuteWithHookContext β•‘
β•‘ hive.exec.post.hooks β•‘ org.apache.hadoop.hive.ql.hooks.ExecuteWithHookContext β•‘
β•‘ hive.exec.failure.hooks β•‘ org.apache.hadoop.hive.ql.hooks.ExecuteWithHookContext β•‘
β•‘ hive.metastore.init.hooks β•‘ org.apache.hadoop.hive.metastore.MetaStoreInitListener β•‘
β•‘ hive.exec.driver.run.hooks β•‘ org.apache.hadoop.hive.ql.HiveDriverRunHook β•‘
β•‘ hive.semantic.analyser.hook β•‘ org.apache.hadoop.hive.ql.parse.AbstractSemanticAnalyzerHook β•‘
β•šβ•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•©β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•
╔═══════════════════════════════════════╦═══════════════════════════════════════════════════════════════╗
β•‘ Property β•‘ Abstract class β•‘
╠═══════════════════════════════════════╬═══════════════════════════════════════════════════════════════╗
β•‘ hive.metastore.pre.event.listeners β•‘ org.apache.hadoop.hive.metastore.MetaStorePreEventListener β•‘
β•‘ hive.metastore.end.function.listeners β•‘ org.apache.hadoop.hive.metastore.MetaStoreEndFunctionListener β•‘
β•‘ hive.metastore.event.listeners β•‘ org.apache.hadoop.hive.metastore.MetaStoreEventListener β•‘
β•šβ•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•©β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•β•
╔═══════════════════════════════════════════════╦════════════════════════╗
β•‘ Method β•‘ Parameter β•‘
╠═══════════════════════════════════════════════╬════════════════════════╗
β•‘ MetaStoreEventListener.onConfigChange β•‘ ConfigChangeEvent β•‘
β•‘ MetaStoreEventListener.onCreateTable β•‘ CreateTableEvent β•‘
β•‘ MetaStoreEventListener.onDropTable β•‘ DropTableEvent β•‘
β•‘ MetaStoreEventListener.onAlterTable β•‘ AlterTableEvent β•‘
β•‘ MetaStoreEventListener.onAddPartition β•‘ AddPartitionEvent β•‘
β•‘ MetaStoreEventListener.onDropPartition β•‘ DropPartitionEvent β•‘
β•‘ MetaStoreEventListener.onAlterPartition β•‘ AlterPartitionEvent β•‘
{
"name": "sample-pubsub",
"version": "0.0.1",
"dependencies": {
"@google-cloud/pubsub": "^0.18.0"
}
}
package com.medium.hive.hook;
import com.fasterxml.jackson.databind.ObjectMapper;
import org.apache.hadoop.hive.ql.QueryPlan;
import org.apache.hadoop.hive.ql.hooks.ExecuteWithHookContext;
import org.apache.hadoop.hive.ql.hooks.HookContext;
import org.apache.hadoop.hive.ql.hooks.HookContext.HookType;
import org.apache.hadoop.hive.ql.hooks.ReadEntity;
import org.apache.hadoop.hive.ql.hooks.WriteEntity;
import org.apache.hadoop.hive.ql.plan.HiveOperation;
package com.medium.hive.metastore.listerner;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hive.metastore.events.AlterTableEvent;
import org.apache.hadoop.hive.metastore.MetaStoreEventListener;
import org.apache.hadoop.hive.metastore.events.CreateTableEvent;
import org.codehaus.jackson.map.ObjectMapper;
new_metadata = metadata.head(1).copy()
for i in range(100):
row = metadata.head(1)
row['table_name'] = row['table_name'] + str(i)
new_metadata = new_metadata.append(row)
@classmethod
def __get_df_memory_usage(cls, key_value, df):
import io
buf = io.StringIO()