@@ -83,7 +83,7 @@ public SnowflakeLogsConnector() {
8383 this ("snowflake-logs" , SCHEMA_ONLY_SOURCE );
8484 }
8585
86- enum SnowflakeLogConnectorProperties implements ConnectorProperty {
86+ enum SnowflakeLogsConnectorProperty implements ConnectorProperty {
8787 OVERRIDE_QUERY ("snowflake.logs.query" , "Custom query for log dump." ),
8888 OVERRIDE_WHERE (
8989 "snowflake.logs.where" , "Custom where condition to append to query for log dump." ),
@@ -124,7 +124,7 @@ enum SnowflakeLogConnectorProperties implements ConnectorProperty {
124124 private final String name ;
125125 private final String description ;
126126
127- SnowflakeLogConnectorProperties (String name , String description ) {
127+ SnowflakeLogsConnectorProperty (String name , String description ) {
128128 this .name = name ;
129129 this .description = description ;
130130 }
@@ -180,7 +180,7 @@ public String getDescription() {
180180 @ Override
181181 @ Nonnull
182182 public ImmutableList <ConnectorProperty > getPropertyConstants () {
183- return stream (SnowflakeLogConnectorProperties .values ()).collect (toImmutableList ());
183+ return stream (SnowflakeLogsConnectorProperty .values ()).collect (toImmutableList ());
184184 }
185185
186186 private String newQueryFormat (@ Nonnull ConnectorArguments arguments )
@@ -322,7 +322,7 @@ static String addOverridesToQuery(
322322 StringBuilder queryBuilder = new StringBuilder (baseQuery );
323323 queryBuilder .append (earliestTimestamp (arguments ));
324324
325- String overrideWhere = arguments .getDefinition (SnowflakeLogConnectorProperties .OVERRIDE_WHERE );
325+ String overrideWhere = arguments .getDefinition (SnowflakeLogsConnectorProperty .OVERRIDE_WHERE );
326326 if (overrideWhere != null ) {
327327 queryBuilder .append (" AND " + overrideWhere );
328328 }
@@ -342,7 +342,7 @@ static String earliestTimestamp(@Nonnull ConnectorArguments arguments) {
342342 @ CheckForNull
343343 private static String getOverrideQuery (@ Nonnull ConnectorArguments arguments )
344344 throws MetadataDumperUsageException {
345- String overrideQuery = arguments .getDefinition (SnowflakeLogConnectorProperties .OVERRIDE_QUERY );
345+ String overrideQuery = arguments .getDefinition (SnowflakeLogsConnectorProperty .OVERRIDE_QUERY );
346346 if (overrideQuery != null ) {
347347 if (StringUtils .countMatches (overrideQuery , "%s" ) != 2 )
348348 throw new MetadataDumperUsageException (
@@ -452,67 +452,67 @@ enum TimeSeriesView {
452452 WarehouseEventsHistoryFormat .Header .class ,
453453 WarehouseEventsHistoryFormat .ZIP_ENTRY_PREFIX ,
454454 TimeSeriesColumn .TIMESTAMP ,
455- SnowflakeLogConnectorProperties .WAREHOUSE_EVENTS_HISTORY_OVERRIDE_QUERY ),
455+ SnowflakeLogsConnectorProperty .WAREHOUSE_EVENTS_HISTORY_OVERRIDE_QUERY ),
456456 AUTOMATIC_CLUSTERING_HISTORY (
457457 AutomaticClusteringHistoryFormat .Header .class ,
458458 AutomaticClusteringHistoryFormat .ZIP_ENTRY_PREFIX ,
459459 TimeSeriesColumn .END_TIME ,
460- SnowflakeLogConnectorProperties .AUTOMATIC_CLUSTERING_HISTORY_OVERRIDE_QUERY ),
460+ SnowflakeLogsConnectorProperty .AUTOMATIC_CLUSTERING_HISTORY_OVERRIDE_QUERY ),
461461 COPY_HISTORY (
462462 CopyHistoryFormat .Header .class ,
463463 CopyHistoryFormat .ZIP_ENTRY_PREFIX ,
464464 TimeSeriesColumn .LAST_LOAD_TIME ,
465- SnowflakeLogConnectorProperties .COPY_HISTORY_OVERRIDE_QUERY ),
465+ SnowflakeLogsConnectorProperty .COPY_HISTORY_OVERRIDE_QUERY ),
466466 DATABASE_REPLICATION_USAGE_HISTORY (
467467 DatabaseReplicationUsageHistoryFormat .Header .class ,
468468 DatabaseReplicationUsageHistoryFormat .ZIP_ENTRY_PREFIX ,
469469 TimeSeriesColumn .END_TIME ,
470- SnowflakeLogConnectorProperties .DATABASE_REPLICATION_USAGE_HISTORY_OVERRIDE_QUERY ),
470+ SnowflakeLogsConnectorProperty .DATABASE_REPLICATION_USAGE_HISTORY_OVERRIDE_QUERY ),
471471 LOGIN_HISTORY (
472472 LoginHistoryFormat .Header .class ,
473473 LoginHistoryFormat .ZIP_ENTRY_PREFIX ,
474474 TimeSeriesColumn .EVENT_TIMESTAMP ,
475- SnowflakeLogConnectorProperties .LOGIN_HISTORY_OVERRIDE_QUERY ),
475+ SnowflakeLogsConnectorProperty .LOGIN_HISTORY_OVERRIDE_QUERY ),
476476 METERING_DAILY_HISTORY (
477477 MeteringDailyHistoryFormat .Header .class ,
478478 MeteringDailyHistoryFormat .ZIP_ENTRY_PREFIX ,
479479 TimeSeriesColumn .USAGE_DATE ,
480- SnowflakeLogConnectorProperties .METERING_DAILY_HISTORY_OVERRIDE_QUERY ),
480+ SnowflakeLogsConnectorProperty .METERING_DAILY_HISTORY_OVERRIDE_QUERY ),
481481 PIPE_USAGE_HISTORY (
482482 PipeUsageHistoryFormat .Header .class ,
483483 PipeUsageHistoryFormat .ZIP_ENTRY_PREFIX ,
484484 TimeSeriesColumn .END_TIME ,
485- SnowflakeLogConnectorProperties .PIPE_USAGE_HISTORY_OVERRIDE_QUERY ),
485+ SnowflakeLogsConnectorProperty .PIPE_USAGE_HISTORY_OVERRIDE_QUERY ),
486486 QUERY_ACCELERATION_HISTORY (
487487 QueryAccelerationHistoryFormat .Header .class ,
488488 QueryAccelerationHistoryFormat .ZIP_ENTRY_PREFIX ,
489489 TimeSeriesColumn .END_TIME ,
490- SnowflakeLogConnectorProperties .QUERY_ACCELERATION_HISTORY_OVERRIDE_QUERY ),
490+ SnowflakeLogsConnectorProperty .QUERY_ACCELERATION_HISTORY_OVERRIDE_QUERY ),
491491 REPLICATION_GROUP_USAGE_HISTORY (
492492 ReplicationGroupUsageHistoryFormat .Header .class ,
493493 QueryAccelerationHistoryFormat .ZIP_ENTRY_PREFIX ,
494494 TimeSeriesColumn .END_TIME ,
495- SnowflakeLogConnectorProperties .REPLICATION_GROUP_USAGE_HISTORY_OVERRIDE_QUERY ),
495+ SnowflakeLogsConnectorProperty .REPLICATION_GROUP_USAGE_HISTORY_OVERRIDE_QUERY ),
496496 SERVERLESS_TASK_HISTORY (
497497 ServerlessTaskHistoryFormat .Header .class ,
498498 ServerlessTaskHistoryFormat .ZIP_ENTRY_PREFIX ,
499499 TimeSeriesColumn .END_TIME ,
500- SnowflakeLogConnectorProperties .SERVERLESS_TASK_HISTORY_OVERRIDE_QUERY ),
500+ SnowflakeLogsConnectorProperty .SERVERLESS_TASK_HISTORY_OVERRIDE_QUERY ),
501501 TASK_HISTORY (
502502 TaskHistoryFormat .Header .class ,
503503 TaskHistoryFormat .ZIP_ENTRY_PREFIX ,
504504 TimeSeriesColumn .COMPLETED_TIME ,
505- SnowflakeLogConnectorProperties .TASK_HISTORY_OVERRIDE_QUERY ),
505+ SnowflakeLogsConnectorProperty .TASK_HISTORY_OVERRIDE_QUERY ),
506506 WAREHOUSE_LOAD_HISTORY (
507507 WarehouseLoadHistoryFormat .Header .class ,
508508 WarehouseLoadHistoryFormat .ZIP_ENTRY_PREFIX ,
509509 TimeSeriesColumn .END_TIME ,
510- SnowflakeLogConnectorProperties .WAREHOUSE_LOAD_HISTORY_OVERRIDE_QUERY ),
510+ SnowflakeLogsConnectorProperty .WAREHOUSE_LOAD_HISTORY_OVERRIDE_QUERY ),
511511 WAREHOUSE_METERING_HISTORY (
512512 WarehouseMeteringHistoryFormat .Header .class ,
513513 WarehouseMeteringHistoryFormat .ZIP_ENTRY_PREFIX ,
514514 TimeSeriesColumn .END_TIME ,
515- SnowflakeLogConnectorProperties .WAREHOUSE_METERING_HISTORY_OVERRIDE_QUERY );
515+ SnowflakeLogsConnectorProperty .WAREHOUSE_METERING_HISTORY_OVERRIDE_QUERY );
516516
517517 final Class <? extends Enum <?>> headerClass ;
518518 final ConnectorProperty property ;
@@ -524,7 +524,7 @@ enum TimeSeriesView {
524524 Class <? extends Enum <?>> headerClass ,
525525 String zipPrefix ,
526526 TimeSeriesColumn column ,
527- SnowflakeLogConnectorProperties property ) {
527+ SnowflakeLogsConnectorProperty property ) {
528528 this .headerClass = headerClass ;
529529 this .property = property ;
530530 this .queryPrefix = formatPrefix (headerClass , name ());
0 commit comments