This file contains 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
| from org.poma.accumulo import Key,KeyValue | |
| from org.apache.accumulo.core.data import Range,Value | |
| from org.apache.hadoop.io import WritableUtils | |
| from java.io import ByteArrayInputStream, DataInputStream | |
| import struct | |
| import json | |
| def swap32(i): | |
| return struct.unpack("<L", struct.pack(">L", i))[0] |
phrocker
/ python lambda
Created
December 12, 2019 15:25
This file contains 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
| from ctypes import cdll | |
| from argparse import ArgumentParser | |
| from ctypes import cdll | |
| import ctypes | |
| import os | |
| import traceback | |
| import sys | |
| import time | |
This file contains 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
| import os | |
| import traceback | |
| import sys | |
| import time | |
| """ | |
| This is an Example of using the Python connectors. The example will accept user input |
This file contains 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
| package org.poma.accumulo.nifi.processors; | |
| import org.apache.accumulo.core.conf.AccumuloConfiguration; | |
| import org.apache.accumulo.core.conf.DefaultConfiguration; | |
| import org.apache.accumulo.core.data.Key; | |
| import org.apache.accumulo.core.data.Value; | |
| import org.apache.accumulo.core.file.FileSKVWriter; | |
| import org.apache.accumulo.core.file.rfile.RFileOperations; | |
| import org.apache.hadoop.conf.Configuration; | |
| import org.apache.hadoop.fs.FileSystem; |
This file contains 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
| package org.poma.accumulo.nifi.processors; | |
| import org.apache.accumulo.core.conf.AccumuloConfiguration; | |
| import org.apache.accumulo.core.conf.DefaultConfiguration; | |
| import org.apache.accumulo.core.data.Key; | |
| import org.apache.accumulo.core.data.Value; | |
| import org.apache.accumulo.core.file.FileSKVWriter; | |
| import org.apache.accumulo.core.file.rfile.RFileOperations; | |
| import org.apache.hadoop.conf.Configuration; | |
| import org.apache.hadoop.fs.FileSystem; |
phrocker
/ example sql
Created
September 20, 2019 14:14
This file contains 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
| MiNiFi Config Version: 3 | |
| Flow Controller: | |
| name: windowsdev | |
| comment: Created by MiNiFi C2 Flow Designer | |
| Core Properties: | |
| flow controller graceful shutdown period: 10 sec | |
| flow service write delay interval: 500 ms | |
| administrative yield duration: 30 sec | |
| bored yield duration: 10 millis | |
| max concurrent threads: 1 |
This file contains 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
| MiNiFi Config Version: 3 | |
| Flow Controller: | |
| name: windowsdev | |
| comment: Created by MiNiFi C2 Flow Designer | |
| Core Properties: | |
| flow controller graceful shutdown period: 10 sec | |
| flow service write delay interval: 500 ms | |
| administrative yield duration: 30 sec | |
| bored yield duration: 10 millis | |
| max concurrent threads: 1 |
phrocker
/ despite all my rage I'm still just a gist in a cage
Created
August 6, 2019 19:14
This file contains 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
| { | |
| "operation": "heartbeat", | |
| "agentInfo": { | |
| "agentManifest": { | |
| "buildInfo": { | |
| "compiler": "/Library/Developer/CommandLineTools/usr/bin/c++", | |
| "flags": " -std=c++11 -DOPENSSL_SUPPORT", | |
| "revision": "678920114a18890879c8069f7da4a18dedc2460d", | |
| "timestamp": 1564593071, | |
| "version": "0.7.0" |
phrocker
/ AgentProperties
Created
July 29, 2019 14:17
This file contains 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
| nifi.c2.root.classes=DeviceInfoNode,AgentInformation,FlowInformation | |
| nifi.c2.root.class.definitions=metrics | |
| nifi.c2.root.class.definitions.metrics.name=metrics | |
| nifi.c2.root.class.definitions.metrics.metrics=typedmetrics | |
| nifi.c2.root.class.definitions.metrics.metrics.typedmetrics.name=RuntimeMetrics | |
| nifi.c2.root.class.definitions.metrics.metrics.queuemetrics.name=QueueMetrics | |
| nifi.c2.root.class.definitions.metrics.metrics.queuemetrics.classes=QueueMetrics | |
| nifi.c2.root.class.definitions.metrics.metrics.typedmetrics.classes=ProcessMetrics,SystemInformation | |
| nifi.c2.root.class.definitions.metrics.metrics.processorMetrics.name=ProcessorMetric | |
| nifi.c2.root.class.definitions.metrics.metrics.processorMetrics.classes=GetFileMetrics |
phrocker
/ Example Flow(rida)
Created
July 26, 2019 11:55
This file contains 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
| MiNiFi Config Version: 3 | |
| Flow Controller: | |
| name: WindowsTest | |
| comment: Created by MiNiFi C2 Flow Designer | |
| Core Properties: | |
| flow controller graceful shutdown period: 10 sec | |
| flow service write delay interval: 500 ms | |
| administrative yield duration: 30 sec | |
| bored yield duration: 10 millis | |
| max concurrent threads: 1 |