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:
| { | |
| "id": 1, | |
| "title": "StreamSets Data Collector", | |
| "originalTitle": "StreamSets Data Collector", | |
| "tags": [], | |
| "style": "dark", | |
| "timezone": "utc", | |
| "editable": true, | |
| "hideControls": false, | |
| "sharedCrosshair": false, |
| 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. |
| datacollector: | |
| image: 'streamsets/datacollector:1.1.4' | |
| environment: | |
| - 'SDC_JAVA_OPTS=-Dcom.sun.management.jmxremote.port=1105 -Dcom.sun.management.jmxremote.authenticate=false -Dcom.sun.management.jmxremote.ssl=false' | |
| expose: | |
| - '1105' | |
| ports: | |
| - '18630:18630' | |
| grafana: | |
| image: 'grafana/grafana:latest' |
| # Host/Port Grahpite listens on | |
| graphite_host: "JMXTRANS_GRAPHITE_HOST" | |
| graphite_port: "JMXTRANS_GRAPHITE_PORT" | |
| # Global port to query JMX on | |
| # query_port and global_host_alias are mandatory | |
| # Will accept a blank space if alias and host is provided in host sets | |
| query_port: "JMXTRANS_JMX_PORT" | |
| global_host_alias: "JMXTRANS_JMX_HOST" |
| 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))' |