Skip to content

Instantly share code, notes, and snippets.


Block or report user

Report or block vvagias

Hide content and notifications from this user.

Learn more about blocking users

Contact Support about this user’s behavior.

Learn more about reporting abuse

Report abuse
View GitHub Profile
vvagias / iot_streaming_example.scala
Created Jan 17, 2020
example flink app for edge2ai workshop iot data.
View iot_streaming_example.scala
package vv
import java.util.{Properties, StringTokenizer}
import org.apache.flink.api.common.functions.{FlatMapFunction, MapFunction}
import org.apache.flink.streaming.api.scala.{StreamExecutionEnvironment, _}
import org.apache.flink.streaming.connectors.kafka.{FlinkKafkaConsumer, FlinkKafkaProducer, FlinkKafkaProducer011}
import org.apache.flink.streaming.util.serialization.JSONKeyValueDeserializationSchema
vvagias / Load-IoT-to-Kafka.xml
Created Jan 17, 2020
NiFi load IoT data into Kafka for Flink lab
View Load-IoT-to-Kafka.xml
<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
<template encoding-version="1.2">
<description>push IoT Data into Kafka highTemp Topic.
<name>IoT Data To Kafka</name>
View classify.json
"label": "bee",
"probability": 0.44016194343566895
"label": "vase",
"probability": 0.13220570981502533
vvagias / graph.json
Last active Dec 14, 2019
sample json for force graph
View graph.json
"name": "v2",
"children": [
"name": "social",
"children": [
"name": "political",
"children": [
vvagias / d3_test.csv
Last active Dec 14, 2019
data for testing d3
View d3_test.csv
name value
a 1
b 2
c 3
d 4
e 5
f 6
g 7
h 8
i 7
vvagias / hive_table_atlas_entity.json
Created Sep 30, 2016
Sample response from Apache Atlas REST entity request
View hive_table_atlas_entity.json
"requestId": "qtp940790097-33208 - f99ee279-719a-4657-a868-5a58a5b64d52",
"definition": {
"jsonClass": "org.apache.atlas.typesystem.json.InstanceSerialization$_Reference",
"id": {
"jsonClass": "org.apache.atlas.typesystem.json.InstanceSerialization$_Id",
"id": "55517c07-1313-4a0a-befe-71f2eea82e85",
"version": 0,
"typeName": "hive_table",
"state": "ACTIVE"
You can’t perform that action at this time.