From a489e36af9a4bc47b09da346ea6612daafa5a684 Mon Sep 17 00:00:00 2001 From: Robin Tang Date: Thu, 21 Nov 2024 11:33:59 -0800 Subject: [PATCH] Adding a comment. --- clients/s3/s3.go | 1 + 1 file changed, 1 insertion(+) diff --git a/clients/s3/s3.go b/clients/s3/s3.go index 10c0ca52..dbb83800 100644 --- a/clients/s3/s3.go +++ b/clients/s3/s3.go @@ -49,6 +49,7 @@ func (s *Store) IdentifierFor(topicConfig kafkalib.TopicConfig, table string) sq func (s *Store) ObjectPrefix(tableData *optimization.TableData) string { tableID := s.IdentifierFor(tableData.TopicConfig(), tableData.Name()) fqTableName := tableID.FullyQualifiedName() + // Adding date= prefix so that it adheres to the partitioning format for Hive. yyyyMMDDFormat := fmt.Sprintf("date=%s", time.Now().Format(ext.PostgresDateFormat)) if len(s.config.S3.FolderName) > 0 { return strings.Join([]string{s.config.S3.FolderName, fqTableName, yyyyMMDDFormat}, "/")