I hereby claim:
- I am kunickiaj on github.
- I am kunickiaj (https://keybase.io/kunickiaj) on keybase.
- I have a public key ASCKol5Y-6Y6DSN7QhQtPudQlpuVhD_1F3P3xANNZgmP0Qo
To claim this, I am signing this object:
| diff --git a/external/kafka/pom.xml b/external/kafka/pom.xml | |
| index 8a43eb7..59e9b62 100644 | |
| --- a/external/kafka/pom.xml | |
| +++ b/external/kafka/pom.xml | |
| @@ -28,6 +28,7 @@ | |
| <artifactId>spark-streaming-kafka_2.10</artifactId> | |
| <properties> | |
| <sbt.project.name>streaming-kafka</sbt.project.name> | |
| + <kafka.version>0.8.2.2.3.2.0-2950</kafka.version> | |
| </properties> |
| # | |
| # Sample Jython code | |
| # | |
| # Available Objects: | |
| # | |
| # records: an array of records to process, depending on Jython processor | |
| # processing mode it may have 1 record or all the records in the batch. | |
| # | |
| # state: a dict that is preserved between invocations of this script. | |
| # Useful for caching bits of data e.g. counters. |
| { | |
| "id": 1, | |
| "title": "StreamSets Data Collector", | |
| "originalTitle": "StreamSets Data Collector", | |
| "tags": [], | |
| "style": "dark", | |
| "timezone": "utc", | |
| "editable": true, | |
| "hideControls": false, | |
| "sharedCrosshair": false, |
| import java.util.*; | |
| import java.io.*; | |
| import java.security.*; | |
| public class ChangePassword | |
| { | |
| private final static JKS j = new JKS(); | |
| public static void main(String[] args) throws Exception | |
| { |
I hereby claim:
To claim this, I am signing this object:
| # | |
| # | |
| # Licensed to the Apache Software Foundation (ASF) under one | |
| # or more contributor license agreements. See the NOTICE file | |
| # distributed with this work for additional information | |
| # regarding copyright ownership. The ASF licenses this file | |
| # to you under the Apache License, Version 2.0 (the | |
| # "License"); you may not use this file except in compliance | |
| # with the License. You may obtain a copy of the License at | |
| # |
| for(var i = 0; i < records.length; i++) { | |
| try { | |
| records[i].value = com.google.common.base.Splitter.on(", ").withKeyValueSeparator("=").split(records[i].value['text']) | |
| // Write record to procesor output | |
| output.write(records[i]); | |
| } catch (e) { | |
| // Send record to error | |
| error.write(records[i], e); | |
| } |
| [alias] | |
| lg = log --color --graph --pretty=format:'%Cred%h%Creset -%C(yellow)%d%Creset %s %Cgreen(%cr) %C(bold blue)<%an>%Creset' --abbrev-commit | |
| bl = for-each-ref --sort=refname:short refs/heads/ --format='%(HEAD) %(color:yellow)%(refname:short)%(color:reset) - %(color:red)%(objectname:short)%(color:reset) - %(contents:subject) - %(authorname) (%(color:green)%(committerdate:relative)%(color:reset))' |
| { | |
| "type": "record", | |
| "name": "RawFlowRecord", | |
| "namespace": "com.cloudera.accelerators.flows.avro", | |
| "fields": [{ | |
| "name": "treceived", | |
| "type": ["string", "null"] | |
| }, { | |
| "name": "tryear", | |
| "type": ["float", "null"] |