Adding a comment.

artie-labs · Nov 21, 2024 · a489e36 · a489e36
1 parent b8fde48
commit a489e36
Showing 1 changed file with 1 addition and 0 deletions.
diff --git 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}, "/")