Hidden objects with unknown types

Author: stas-panasiuk

flink-cyber/flink-indexing/flink-indexing-hive/src/main/java/com/cloudera/cyber/indexing/hive/util/FlinkSchemaUtil.java

@@ -1,29 +1,29 @@
 package com.cloudera.cyber.indexing.hive.util;
 
 import com.cloudera.cyber.indexing.TableColumnDto;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Optional;
+import java.util.stream.Collectors;
 import org.apache.flink.table.api.DataTypes;
 import org.apache.flink.table.api.Schema;
 import org.apache.flink.table.catalog.Column;
 import org.apache.flink.table.catalog.ResolvedSchema;
 import org.apache.flink.table.types.DataType;
 
-import java.util.ArrayList;
-import java.util.List;
-import java.util.Optional;
-import java.util.stream.Collectors;
-
 public final class FlinkSchemaUtil {
 
     public static Schema buildSchema(ResolvedSchema resolvedSchema) {
         return Schema.newBuilder()
-              .fromResolvedSchema(resolvedSchema)
-              .build();
+                     .fromResolvedSchema(resolvedSchema)
+                     .build();
     }
 
     public static ResolvedSchema getResolvedSchema(List<TableColumnDto> columnList) {
         final List<Column> flinkColumnList = columnList.stream()
-              .map(col -> Column.physical(col.getName(), getFlinkType(col.getType(), col.getNullable())))
-              .collect(Collectors.toList());
+                                                       .map(col -> Column.physical(col.getName(),
+                                                             getFlinkType(col.getType(), col.getNullable())))
+                                                       .collect(Collectors.toList());
         return ResolvedSchema.of(flinkColumnList);
     }
 

flink-cyber/metron-parser-chain/parser-chains-config-service/src/main/java/com/cloudera/parserchains/queryservice/config/kafka/KafkaConfig.java

@@ -40,7 +40,7 @@
 public class KafkaConfig {
 
     /**
-     * Provides the default kafka properties for the consumers
+     * Provides the default kafka properties for the consumers.
      *
      * @return Default kafka properties for the consumers
      */
@@ -50,10 +50,11 @@ public ClouderaKafkaProperties kafkaProperties() {
         return new ClouderaKafkaProperties();
     }
 
-    /***
-     * Provides a map with key=clusterId and value=ClouderaKafkaProperties
+    /**
+     * Provides a map with key=clusterId and value=ClouderaKafkaProperties.
      *
-     * @return Map with key of clusterId and value - kafkaProperties. This map is a mapping between clusterId and connection details for that cluster
+     * @return Map with key of clusterId and value - kafkaProperties.
+     *       This map is a mapping between clusterId and connection details for that cluster
      */
     @Bean(name = "kafka-external-cluster-map")
     @Scope(ConfigurableBeanFactory.SCOPE_SINGLETON)

flink-cyber/metron-parser-chain/parser-chains-config-service/src/main/java/com/cloudera/parserchains/queryservice/model/describe/OcsfIndexMappingDescriptor.java

@@ -1,11 +1,10 @@
 package com.cloudera.parserchains.queryservice.model.describe;
 
 import com.cloudera.cyber.indexing.MappingDto;
+import java.util.Map;
 import lombok.Getter;
 import lombok.Setter;
 
-import java.util.Map;
-
 @Getter
 @Setter
 public class OcsfIndexMappingDescriptor extends IndexMappingDescriptor {

flink-cyber/metron-parser-chain/parser-chains-config-service/src/main/java/com/cloudera/parserchains/queryservice/service/OcsfService.java

@@ -1,10 +1,6 @@
 package com.cloudera.parserchains.queryservice.service;
 
 
-import lombok.RequiredArgsConstructor;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.stereotype.Service;
-
 import java.io.IOException;
 import java.net.URI;
 import java.net.URISyntaxException;
@@ -14,6 +10,9 @@
 import java.nio.file.Files;
 import java.nio.file.Paths;
 import java.util.Collections;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
 
 @Slf4j
 @Service

flink-cyber/metron-parser-chain/parser-chains-core/src/main/java/com/cloudera/parserchains/core/ReflectiveParserBuilder.java

@@ -110,8 +110,8 @@ private void configureParams(ParserSchema parserSchema, List<ConfigValueSchema>
                     throw new InvalidParserException(parserSchema,
                           String.format("Required parameter isn't provided: %s", annotationKey));
                 }
-                if (paramAnnotation.isPath() && parserSchema.getBasePath() != null &&
-                    !parserSchema.getBasePath().equals("null")) {
+                if (paramAnnotation.isPath() && parserSchema.getBasePath() != null
+                        && !parserSchema.getBasePath().equals("null")) {
                     finalValue = Paths.get(parserSchema.getBasePath(), finalValue).toString();
                 }
                 valueMap.put(annotationKey, finalValue);

flink-cyber/metron-parser-chain/parser-chains-core/src/main/java/com/cloudera/parserchains/core/catalog/Configurable.java

@@ -79,6 +79,7 @@
 
     /**
      * If true, the value will be treated as path and can be appended with base directory.
+     *
      * <p>This value is optional.
      */
     boolean isPath() default false;

flink-cyber/metron-parser-chain/parser-chains-core/src/main/java/com/cloudera/parserchains/core/catalog/Parameter.java

@@ -78,6 +78,7 @@
 
     /**
      * If true, the value will be treated as path and can be appended with base directory.
+     *
      * <p>This value is optional.
      */
     boolean isPath() default false;