Skip to content

Instantly share code, notes, and snippets.

@pavangadagi

pavangadagi/sparkConfig.java

Last active March 25, 2020 09:31
Show Gist options
  • Save pavangadagi/e9ff6be5642859e24873e67bf52f82ba to your computer and use it in GitHub Desktop.
Save pavangadagi/e9ff6be5642859e24873e67bf52f82ba to your computer and use it in GitHub Desktop.
Download ZIP
Raw
sparkConfig.java
int STREAM_INTERVAL_SEC = 60;
SparkConf sparkConf = new SparkConf().setAppName("CryptoStockAnalysis").setMaster("local[*]");
JavaStreamingContext streamingContext = new JavaStreamingContext(
sparkConf,
Durations.seconds(STREAM_INTERVAL_SEC)
);
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment