Hakan İlter hakanilter
hakanilter
/ EmbeddedDynamoDB.java
Last active
July 7, 2017 15:10
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| /** | |
| <properties> | |
| <sqlite4java.version>1.0.392</sqlite4java.version> | |
| </properties> | |
| <dependencies> | |
| <dependency> | |
| <groupId>com.almworks.sqlite4java</groupId> | |
| <artifactId>sqlite4java</artifactId> | |
| <version>${sqlite4java.version}</version> |
hakanilter
/ pyro-collector.js
Last active
March 2, 2018 14:10
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| /* | |
| * PyroCollector : Clickstream Collector Client | |
| * (c)2018 DataPyro.com | |
| */ | |
| // set your endpoint | |
| var endPoint = "https://d1q9rxqnug6ou7.cloudfront.net/public/blank.gif?"; | |
| // collector | |
| var pyroCollector = { | |
| collect: function(obj) { | |
| if (typeof(obj) !== undefined) { |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Stream<Supplier<String>> calls = list.stream().map(value -> () -> callMe(value)); | |
| List<String> results = calls | |
| .map(CompletableFuture::supplyAsync).collect(Collectors.toList()) | |
| .stream() | |
| .map(CompletableFuture::join).collect(Collectors.toList()); |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| mvn clean package -DskipTests \ | |
| -Phive \ | |
| -Phive-thriftserver \ | |
| -Pyarn \ | |
| -Psparkr \ | |
| -Phadoop-2.6 \ | |
| -Dhadoop.version=2.6.0-cdh5.7.1 \ | |
| -Dhive.hive.version=1.1.0-cdh5.7.1 \ | |
| -Dhive.hadoop.version=2.6.0-cdh5.7.1 |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| mvn clean package -DskipTests \ | |
| -Pr \ | |
| -Pspark-1.6 \ | |
| -Psparkr \ | |
| -Phadoop-2.6 \ | |
| -Dspark.version=1.6.2 \ | |
| -Dhadoop.version=2.6.0-cdh5.7.1 \ | |
| -Dhbase.hbase.version=1.2.0-cdh5.7.1 \ | |
| -Dhbase.hadoop.version=2.6.0-cdh5.7.1 \ | |
| -Dhive.hive.version=1.1.0-cdh5.7.1 \ |
hakanilter
/ gist:529e292d19c4b82ccb684a7d6c179589
Created
September 21, 2016 07:53
Zeppelin Tutorial fails
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| INFO [2016-09-21 07:51:29,993] ({pool-2-thread-3} SchedulerFactory.java[jobStarted]:131) - Job remoteInterpretJob_1474444289992 started by scheduler org.apache.zeppelin.spark.SparkInterpreter1153170779 | |
| INFO [2016-09-21 07:51:30,682] ({pool-2-thread-3} Logging.scala[logInfo]:58) - Starting job: take at NativeMethodAccessorImpl.java:-2 | |
| INFO [2016-09-21 07:51:30,709] ({dag-scheduler-event-loop} Logging.scala[logInfo]:58) - Registering RDD 8 (take at NativeMethodAccessorImpl.java:-2) | |
| INFO [2016-09-21 07:51:30,712] ({dag-scheduler-event-loop} Logging.scala[logInfo]:58) - Got job 0 (take at NativeMethodAccessorImpl.java:-2) with 200 output partitions | |
| INFO [2016-09-21 07:51:30,712] ({dag-scheduler-event-loop} Logging.scala[logInfo]:58) - Final stage: ResultStage 1 (take at NativeMethodAccessorImpl.java:-2) | |
| INFO [2016-09-21 07:51:30,713] ({dag-scheduler-event-loop} Logging.scala[logInfo]:58) - Parents of final stage: List(ShuffleMapStage 0) | |
| INFO [2016-09-21 07:51:30,714] ({dag-scheduler-event-loop} Logging.sca |
NewerOlder