| 第一步，在/etc/yum.repos.d/目录下创建一个源配置文件nginx.repo： | |
| cd /etc/yum.repos.d/ | |
| vim nginx.repo | |
| 填写如下内容： | |
| [nginx] | |
| name=nginx repo |
| package com.datastax.spark.demo; | |
| import com.datastax.driver.core.Session; | |
| import com.datastax.spark.connector.cql.CassandraConnector; | |
| import com.google.common.base.Optional; | |
| import org.apache.spark.SparkConf; | |
| import org.apache.spark.api.java.JavaPairRDD; | |
| import org.apache.spark.api.java.JavaRDD; | |
| import org.apache.spark.api.java.JavaSparkContext; | |
| import org.apache.spark.api.java.function.FlatMapFunction; |
| import com.datastax.driver.core.*; | |
| public class GettingStarted { | |
| public static void main(String[] args) { | |
| Cluster cluster; | |
| Session session; |
Two Storm supervisors running in a 3-node configuration: one "head" node (nimbus) and two worker nodes. Each supervisor node runs a supervisor under supervision.
Multi-lang topology using Python and our streamparse library. Works fine when running on a single machine. Spout reads off Kafka and inserts tuples into
| #!/usr/bin/env bash | |
| # This file contains environment variables required to run Spark. Copy it as | |
| # spark-env.sh and edit that to configure Spark for your site. | |
| # | |
| # The following variables can be set in this file: | |
| # - SPARK_LOCAL_IP, to set the IP address Spark binds to on this node | |
| # - MESOS_NATIVE_LIBRARY, to point to your libmesos.so if you use Mesos | |
| # - SPARK_JAVA_OPTS, to set node-specific JVM options for Spark. Note that | |
| # we recommend setting app-wide options in the application's driver program. |
| // Traverses an arbitrary struct and translates all stings it encounters | |
| // | |
| // I haven't seen an example for reflection traversing an arbitrary struct, so | |
| // I want to share this with you. If you encounter any bugs or want to see | |
| // another example please comment. | |
| // | |
| // The MIT License (MIT) | |
| // | |
| // Copyright (c) 2014 Heye Vöcking | |
| // |
| from pyelasticsearch import ElasticSearch | |
| import pandas as pd | |
| from time import time | |
| root_path="/home/clemsos/Dev/mitras/" | |
| raw_data_path=root_path+"data/" | |
| csv_filename="week10.csv" | |
| t0=time() |
| #!/bin/sh | |
| exec < /dev/tty | |
| ./.git/hooks/validate_commit.rb $1 |
| <html> | |
| <head> | |
| <title>WebSocket demo</title> | |
| </head> | |
| <body> | |
| <div> | |
| <form> | |
| <label for="numberfield">Number</label> | |
| <input type="text" id="numberfield" placeholder="12"/><br /> |
