Skip to content

Instantly share code, notes, and snippets.

View l15k4's full-sized avatar
🎯
Focusing

Jakub Liska l15k4

🎯
Focusing
View GitHub Profile
root@2c60002355dd:~/imply-1.0.2# ps aux
root 34 0.7 1.9 4140732 325552 ? Sl 17:05 0:28 java -server -Xms256m -Xmx512m -Duser.timezone=UTC -Dfile.encoding=UTF-8 -Djava.io.tmpdir=var/tmp -Djava.util.logging.manager=org.apache.logging.log4j.jul.LogManager -Dderby.stream.error.file=var/druid/derby.log -cp /root/imply-1.0.2/conf-quickstart/druid/_common:/root/imply-1.0.2/conf-quickstart/druid/coordinator:/root/imply-1.0.2/bin/../dist/druid/lib/RoaringBitmap-0.5.4.jar:/root/imply-1.0.2/bin/../dist/druid/lib/activation-1.1.1.jar:/root/imply-1.0.2/bin/../dist/druid/lib/aether-api-0.9.0.M2.jar:/root/imply-1.0.2/bin/../dist/druid/lib/aether-connector-file-0.9.0.M2.jar:/root/imply-1.0.2/bin/../dist/druid/lib/aether-connector-okhttp-0.0.9.jar:/root/imply-1.0.2/bin/../dist/druid/lib/aether-impl-0.9.0.M2.jar:/root/imply-1.0.2/bin/../dist/druid/lib/aether-spi-0.9.0.M2.jar:/root/imply-1.0.2/bin/../dist/druid/lib/aether-util-0.9.0.M2.jar:/root/imply-1.0.2/bin/../dist/druid/lib/airline-0.7.jar:/root/imply-1.0
root@2c60002355dd:~/imply-1.0.2# ps aux
USER PID %CPU %MEM VSZ RSS TTY STAT START TIME COMMAND
root 1 0.0 0.0 27212 4564 ? Ss 17:05 0:00 perl bin/supervise -c conf/supervise/quickstart.conf
root 33 0.1 0.3 2966920 64724 ? Sl 17:05 0:03 java -server -Xms256m -Xmx256m -Duser.timezone=UTC -cp /root/imply-1.0.2/bin/../dist/zk/lib/*:/root/imply-1.0.2/bin/../dist/zk/*:/root/imply-1.0.2/conf-quickstart/zk org.apac
root 34 0.7 1.9 4140732 325552 ? Sl 17:05 0:28 java -server -Xms256m -Xmx512m -Duser.timezone=UTC -Dfile.encoding=UTF-8 -Djava.io.tmpdir=var/tmp -Djava.util.logging.manager=org.apache.logging.log4j.jul.LogManager -Dderby.
root 35 0.4 2.6 4623384 431560 ? Sl 17:05 0:16 java -server -Xms1g -Xmx1g -XX:MaxDirectMemorySize=1280m -Duser.timezone=UTC -Dfile.encoding=UTF-8 -Djava.io.tmpdir=var/tmp -Djava.util.logging.manager=org.apache.logging.log
root 36 0.3 2.3 5631376 389032 ? Sl
{
"type" : "index_hadoop",
"spec" : {
"dataSchema" : {
"dataSource" : "gwiq",
"parser" : {
"type" : "hadoopyString",
"parseSpec" : {
"format" : "json",
"timestampSpec" : {
{
"type" : "index_hadoop",
"spec" : {
"dataSchema" : {
"dataSource" : "gwiq",
"parser" : {
"type" : "hadoopyString",
"parseSpec" : {
"format" : "json",
"timestampSpec" : {
{
"value" : {
"id" : "merged",
"intervals" : [ "2015-07-01T01:00:00.000Z/2015-07-10T00:00:00.000Z" ],
"columns" : {
"d_b" : {
"type" : "STRING",
"size" : 3883,
"cardinality" : 4
},
{
"value":{
"id":"gwiq_2015-07-01T01:00:00.000Z_2015-07-01T02:00:00.000Z_2016-03-01T18:43:54.350Z",
"intervals":[
"2015-07-01T01:00:00.000Z/2015-07-01T02:00:00.000Z"
],
"columns":{
"d_b":{
"type":"STRING",
"size":16,
trait ResponseReader[Q <: Query, R <: Response, C[X] <: TraversableOnce[X]] {
def read(response: String): C[R]
}
object ResponseReader {
implicit object SelectResponseReader extends ResponseReader[SelectQuery, SelectResponse, Option] {
def read(json: String): Option[SelectResponse] = ObjMapper.readValue[List[SelectResponse]](json).headOption
}
implicit object TimeSeriesResponseReader extends ResponseReader[TimeSeriesQuery, TimeSeriesResponse, Option] {
def read(json: String): Option[TimeSeriesResponse] = ObjMapper.readValue[List[TimeSeriesResponse]](json).headOption
{
"queryType": "timeseries",
"dataSource": "gwiq",
"intervals": [
"2015-01-01T00Z/2015-01-01T04Z"
],
"granularity": "day",
"aggregations": [
{
"type": "hyperUnique",
{
"type" : "index_hadoop",
"spec" : {
"dataSchema" : {
"dataSource" : "gwiq",
"parser" : {
"type" : "hadoopyString",
"parseSpec" : {
"format" : "json",
"timestampSpec" : {
{
"type" : "index_hadoop",
"spec" : {
"dataSchema" : {
"dataSource" : "wikipedia",
"parser" : {
"type" : "hadoopyString",
"parseSpec" : {
"format" : "json",
"timestampSpec" : {