bziobrowski commented on code in PR #14298:
URL: https://github.com/apache/pinot/pull/14298#discussion_r1819303257
##########
pinot-core/src/main/java/org/apache/pinot/core/operator/transform/transformer/datetime/DateTimeTransformerFactory.java:
##########
@@ -29,23 +30,39 @@ private DateTimeTransformerFactory() {
public static BaseDateTimeTransformer getDateTimeTransformer(String
inputFormatStr, String outputFormatStr,
String outputGranularityStr) {
+ return getDateTimeTransformer(inputFormatStr, outputFormatStr,
outputGranularityStr, null);
+ }
+
+ public static BaseDateTimeTransformer getDateTimeTransformer(String
inputFormatStr, String outputFormatStr,
+ String outputGranularityStr, String bucketTimeZoneStr) {
+
DateTimeFormatSpec inputFormat = new DateTimeFormatSpec(inputFormatStr);
DateTimeFormatSpec outputFormat = new DateTimeFormatSpec(outputFormatStr);
DateTimeGranularitySpec outputGranularity = new
DateTimeGranularitySpec(outputGranularityStr);
+ DateTimeZone bucketingTz = null;
+ if (bucketTimeZoneStr != null) {
+ try {
+ // we're not using TimeZone.getTimeZone() because it's globally
synchronized and returns default TZ when str
Review Comment:
Replaced timezone parsing with ZoneId.of().
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
