akhld

import org.apache.spark.SparkConf;
import org.apache.spark.SparkContext;
import org.apache.spark.api.java.JavaRDD;
import org.apache.spark.api.java.function.Function;
import org.apache.spark.streaming.Durations;
import org.apache.spark.streaming.api.java.JavaDStream;
import org.apache.spark.streaming.api.java.JavaStreamingContext;
import org.apache.spark.streaming.scheduler.*;

yellow-sky

#!/usr/bin/python
# coding=utf-8
import sqlite3
import re
import sys
from os import path, rename, walk, mkdir
import shutil

PAGE_QUERY = '''
  select