Index

A

AbstractDatum (class in demo_utils.generator) add_nifi_templates() (in module demo_utils.service_installer) add_zeppelin_notebooks() (in module demo_utils.service_installer)

Ambari (class in demo_utils.ambari) app_name (demo_app.cluster.WSEcho attribute)

B

BooleanDatum (class in demo_utils.generator)

broadcast() (demo_app.cluster.WSDemoApp method) (demo_app.cluster.WSDemoServer method)

C

check() (demo_utils.generator.AbstractDatum method) (demo_utils.generator.BooleanDatum method) (demo_utils.generator.MapDatum method) (demo_utils.generator.NumberDatum method) (demo_utils.generator.StringDatum method) check_ambari_service_installed() (in module demo_utils.service_installer) check_for_key() (demo_utils.generator.AbstractDatum method) check_schema() (demo_utils.generator.DataGenerator method)

closed() (demo_app.cluster.WSEcho method) cmd (demo_utils.curl_client.CurlClient attribute) create_demo_kafka_topic() (in module demo_app.cluster) CurlClient (class in demo_utils.curl_client)

D

DataGenerator (class in demo_utils.generator) DecimalDatum (class in demo_utils.generator) demo_app (module) demo_app.cluster (module) demo_app.demo_server (module) demo_app.service (module) demo_utils (module) demo_utils.ambari (module)

demo_utils.config (module) demo_utils.curl_client (module) demo_utils.generator (module) demo_utils.logs (module) demo_utils.service_installer (module) demo_utils.shell (module) dt (in module demo_app.demo_server)

E

export_file() (demo_app.cluster.ThreadedGenerator method) export_hdfs() (demo_app.cluster.ThreadedGenerator method)

export_http() (demo_app.cluster.ThreadedGenerator method) export_kafka() (demo_app.cluster.ThreadedGenerator method)

G

generate() (demo_utils.generator.AbstractDatum method) (demo_utils.generator.BooleanDatum method) (demo_utils.generator.DataGenerator method) (demo_utils.generator.IntDatum method) (demo_utils.generator.MapDatum method) (demo_utils.generator.NumberDatum method) (demo_utils.generator.StringDatum method) generate_queries() (in module demo_app.cluster) GET() (in module demo_app.demo_server), [1] get_cluster_info() (demo_utils.ambari.Ambari method) get_clusters() (demo_utils.ambari.Ambari method) get_conf_dir() (in module demo_utils.config) get_config() (in module demo_utils.config) get_kafka_topics() (in module demo_app.cluster) get_path() (in module demo_utils.config)

get_sample() (in module demo_app.demo_server) get_schema() (in module demo_app.demo_server) get_service() (demo_utils.ambari.Ambari method) get_services() (demo_utils.ambari.Ambari method) get_test_queries() (in module demo_app.demo_server) get_zeppelin_session() (in module demo_utils.service_installer) getLogFile() (demo_utils.logs.Logger method) getLogger() (demo_utils.logs.Logger method) getLoggingLevel() (demo_utils.logs.Logger method)

H

HIVE_TYPE_MAP (in module demo_app.cluster)

I

index() (in module demo_app.demo_server) install_hdp_select() (in module demo_utils.service_installer) install_nifi() (in module demo_utils.service_installer) install_zeppelin() (in module demo_utils.service_installer)

IntDatum (class in demo_utils.generator) is_ambari_installed() (in module demo_utils.service_installer) is_hdp_select_installed() (in module demo_utils.service_installer)

K

kerberize() (in module demo_app.cluster)

L

load_output() (demo_utils.ambari.Ambari static method) Logger (class in demo_utils.logs)

logger (demo_utils.logs.Logger attribute)

M

make_request() (demo_utils.curl_client.CurlClient method)

MapDatum (class in demo_utils.generator)

N

NumberDatum (class in demo_utils.generator)

O

on_service_install() (in module demo_app.service) on_service_start() (in module demo_app.service) on_service_stop() (in module demo_app.service)

opened() (demo_app.cluster.WSEcho method) OUTPUTS (in module demo_app.demo_server)

P

password (demo_utils.ambari.Ambari attribute) (demo_utils.curl_client.CurlClient attribute) port (demo_utils.ambari.Ambari attribute) (demo_utils.curl_client.CurlClient attribute) post_notebook() (in module demo_utils.service_installer)

post_template() (in module demo_utils.service_installer) proto (demo_utils.ambari.Ambari attribute) (demo_utils.curl_client.CurlClient attribute) push_websockets() (in module demo_app.demo_server)

R

read_config() (in module demo_utils.config) read_xml_config() (in module demo_utils.config)

received_message() (demo_app.cluster.WSEcho method) run() (demo_app.cluster.ThreadedGenerator method) (demo_app.cluster.WSDemoServer method) (demo_utils.shell.Shell method)

S

server (demo_utils.ambari.Ambari attribute) (demo_utils.curl_client.CurlClient attribute) service_action() (demo_utils.ambari.Ambari method) set_cwd() (demo_utils.shell.Shell method) set_password() (demo_utils.ambari.Ambari method) (demo_utils.curl_client.CurlClient method) set_port() (demo_utils.ambari.Ambari method) (demo_utils.curl_client.CurlClient method) set_proto() (demo_utils.ambari.Ambari method) (demo_utils.curl_client.CurlClient method) set_server() (demo_utils.ambari.Ambari method) (demo_utils.curl_client.CurlClient method) set_service_wait_time() (demo_utils.ambari.Ambari method)

set_username() (demo_utils.ambari.Ambari method) (demo_utils.curl_client.CurlClient method) Shell (class in demo_utils.shell) SPARK_TYPE_MAP (in module demo_app.cluster) start_data() (in module demo_app.demo_server) stop() (demo_app.cluster.ThreadedGenerator method) (demo_app.cluster.WSDemoServer method) stop_data() (in module demo_app.demo_server) StringDatum (class in demo_utils.generator)

T

ThreadedGenerator (class in demo_app.cluster)

U

update_data() (in module demo_app.demo_server)

username (demo_utils.ambari.Ambari attribute) (demo_utils.curl_client.CurlClient attribute)

W

ws_app (in module demo_app.demo_server) ws_port (in module demo_app.demo_server) WSDemoApp (class in demo_app.cluster)

WSDemoServer (class in demo_app.cluster) WSEcho (class in demo_app.cluster)