Lars-Kristian Svenøy
01/13/2022, 6:38 PMSELECT dimension FROM table WHERE some_id = 'identifier' GROUP BY LASTWITHTIME(dimension, timestamp, 'String')
bharath holla
01/14/2022, 12:56 PMSandeep R
01/18/2022, 2:24 AMconsole-consumer-32555
console-consumer-37046
console-consumer-3568
console-consumer-11198
table config:
{
"REALTIME": {
"tableName": "uapi-testing_REALTIME",
"tableType": "REALTIME",
"segmentsConfig": {
"schemaName": "uapi-testing",
"timeColumnName": "timestamp",
"replication": "2",
"replicasPerPartition": "2"
},
"tenants": {
"broker": "DefaultTenant",
"server": "DefaultTenant",
"tagOverrideConfig": {}
},
"tableIndexConfig": {
"streamConfigs": {
"streamType": "kafka",
"stream.kafka.topic.name": "uapitranlog2",
"stream.kafka.broker.list": "localhost:6667",
"stream.kafka.consumer.type": "lowlevel",
"stream.kafka.consumer.prop.auto.offset.reset": "smallest",
"stream.kafka.consumer.factory.class.name": "org.apache.pinot.plugin.stream.kafka20.KafkaConsumerFactory",
"stream.kafka.decoder.class.name": "org.apache.pinot.plugin.stream.kafka.KafkaJSONMessageDecoder",
"realtime.segment.flush.threshold.rows": "0",
"realtime.segment.flush.threshold.time": "240h",
"realtime.segment.flush.segment.size": "100M"
},
"createInvertedIndexDuringSegmentGeneration": false,
"invertedIndexColumns": [],
"rangeIndexColumns": [],
"autoGeneratedInvertedIndex": false,
"sortedColumn": [],
"bloomFilterColumns": [],
"loadMode": "MMAP",
"noDictionaryColumns": [],
"onHeapDictionaryColumns": [],
"varLengthDictionaryColumns": [],
"enableDefaultStarTree": false,
"enableDynamicStarTreeCreation": false,
"aggregateMetrics": false,
"nullHandlingEnabled": false
},
"metadata": {},
"quota": {},
"routing": {},
"query": {},
"ingestionConfig": {},
"isDimTable": false
}
}
Prashant Pandey
01/19/2022, 12:07 PMval1,val2,token,val3
to
val1,val2,[redacted],val3
My Google-fu hasn’t been of much help. How can I do this though the query console?Prashant Pandey
01/19/2022, 2:33 PMDELETE from tableName where predicate1
gives me a:
org.apache.pinot.sql.parsers.SqlCompilationException: Caught exception while parsing query: DELETE FROM from baseballStats where baseOnBalls=0
Zsolt Takacs
01/19/2022, 4:01 PMMesut Özen
01/19/2022, 10:08 PMSahar
01/20/2022, 2:39 PMLaxman Ch
01/20/2022, 7:45 PMsuraj kamath
01/21/2022, 10:19 AMAbhishek Tomar
01/21/2022, 10:25 AMLars-Kristian Svenøy
01/21/2022, 11:09 AMSahar
01/21/2022, 3:25 PMabhinav wagle
01/21/2022, 11:10 PMPinot-Admin
utilities inside airflow (https://airflow.apache.org/docs/apache-airflow-providers-apache-pinot/stable/installing-providers-from-sources.html)Prateek Singhal
01/22/2022, 12:34 AMDan DC
01/24/2022, 11:12 AMpinot-admin.sh -v
but that gives me th version of each jar on the node where it runs, this is not exactly what I'm looking forKarin Wolok
Hassane Moustapha
01/25/2022, 9:01 AMEvan Galpin
01/26/2022, 3:55 PMDiogo Baeder
01/26/2022, 6:56 PMManish Soni
01/27/2022, 12:31 PMSahar
01/27/2022, 2:54 PMShawn Peng
01/27/2022, 6:45 PMPinot does not support pagination for aggregation/group
, is it still the case now? Is there any plan to support it?Chris Prokopiak
01/27/2022, 9:01 PMSahar
01/28/2022, 4:35 PMSowmiya
01/31/2022, 9:02 AMShaun Sawyer
02/02/2022, 3:34 PMBe careful when you’re using Groovy, with the recent log4J security is definitely important, make sure you know what you’re doing with that feature. I would suggest turning it off if you don’t really need that feature, although it’s very useful because it helps in terms of just writing your own custom function without having to understand Pinot internal details. And once you get the functionality, then you end up going and writing your own UDF.(https://www.startree.ai/blogs/apache-pinot-2021-recap-and-2022-roadmap) Is it now recommended to avoid Groovy for ingestion transforms, or perhaps there are certain patterns one should avoid for security reasons?
Ian Chen
02/02/2022, 7:50 PMKarin Wolok
Dan DC
02/03/2022, 11:09 AM