Fixed linter issues

airbytehq · Dec 16, 2022 · aa6dc13 · aa6dc13
1 parent 62b9cbb
commit aa6dc13
Show file tree

Hide file tree

Showing 5 changed files with 21 additions and 11 deletions.
diff --git a/airbyte-commons/src/main/java/io/airbyte/commons/features/EnvVariableFeatureFlags.java b/airbyte-commons/src/main/java/io/airbyte/commons/features/EnvVariableFeatureFlags.java
@@ -12,7 +12,8 @@ public class EnvVariableFeatureFlags implements FeatureFlags {
 
   public static final String USE_STREAM_CAPABLE_STATE = "USE_STREAM_CAPABLE_STATE";
   public static final String AUTO_DETECT_SCHEMA = "AUTO_DETECT_SCHEMA";
-  // Set this value to true to see all messages from the source to destination, set to one second emission
+  // Set this value to true to see all messages from the source to destination, set to one second
+  // emission
   public static final String LOG_CONNECTOR_MESSAGES = "LOG_CONNECTOR_MESSAGES";
   public static final String NEED_STATE_VALIDATION = "NEED_STATE_VALIDATION";
   public static final String APPLY_FIELD_SELECTION = "APPLY_FIELD_SELECTION";

diff --git a/...ava/src/main/java/io/airbyte/integrations/base/FailureTrackingAirbyteMessageConsumer.java b/...ava/src/main/java/io/airbyte/integrations/base/FailureTrackingAirbyteMessageConsumer.java
@@ -15,8 +15,10 @@
  *
  * Two methods are intended for extension:
  * <ul>
- * <li>startTracked: Wraps set up of necessary infrastructure/configuration before message consumption.</li>
- * <li>acceptTracked: Wraps actual processing of each {@link io.airbyte.protocol.models.v0.AirbyteMessage}.</li>
+ * <li>startTracked: Wraps set up of necessary infrastructure/configuration before message
+ * consumption.</li>
+ * <li>acceptTracked: Wraps actual processing of each
+ * {@link io.airbyte.protocol.models.v0.AirbyteMessage}.</li>
  * </ul>
  *
  * Though not necessary, we highly encourage using this class when implementing destinations. See

diff --git a/...tegrations/destination/dest_state_lifecycle_manager/DefaultDestStateLifecycleManager.java b/...tegrations/destination/dest_state_lifecycle_manager/DefaultDestStateLifecycleManager.java
@@ -19,10 +19,14 @@
  * during a sync, so a single instance of this manager is sufficient for a destination to track
  * state during a sync.
  *
- * <p>Strategy: Delegates state messages of each type to a StateManager that is appropriate to that
- * state type.</p>
+ * <p>
+ * Strategy: Delegates state messages of each type to a StateManager that is appropriate to that
+ * state type.
+ * </p>
  *
- * <p>Per the protocol, if state type is not set, assumes the LEGACY state type.</p>
+ * <p>
+ * Per the protocol, if state type is not set, assumes the LEGACY state type.
+ * </p>
  */
 public class DefaultDestStateLifecycleManager implements DestStateLifecycleManager {
 

diff --git a/...ntegrations/destination/dest_state_lifecycle_manager/DestStreamStateLifecycleManager.java b/...ntegrations/destination/dest_state_lifecycle_manager/DestStreamStateLifecycleManager.java
@@ -22,10 +22,12 @@
  * stream. In these cases, at each state of the process, it tracks the LAST state message for EACH
  * stream (no duplicates!).
  *
- * <p>Guaranteed to output state messages in order relative to other messages of the SAME state. Does
+ * <p>
+ * Guaranteed to output state messages in order relative to other messages of the SAME state. Does
  * NOT guarantee that state messages of different streams will be output in the order in which they
  * were received. State messages across streams will be emitted in alphabetical order (primary sort
- * on namespace, secondary on name).</p>
+ * on namespace, secondary on name).
+ * </p>
  */
 public class DestStreamStateLifecycleManager implements DestStateLifecycleManager {
 

diff --git a/...n/java/io/airbyte/integrations/destination/record_buffer/SerializedBufferingStrategy.java b/...n/java/io/airbyte/integrations/destination/record_buffer/SerializedBufferingStrategy.java
@@ -31,7 +31,8 @@ public class SerializedBufferingStrategy implements BufferingStrategy {
   private final ConfiguredAirbyteCatalog catalog;
 
   /**
-   * Creates instance of Serialized Buffering Strategy used to handle the logic of flushing buffer with an associated buffer type
+   * Creates instance of Serialized Buffering Strategy used to handle the logic of flushing buffer
+   * with an associated buffer type
    *
    * @param onCreateBuffer type of buffer used upon creation
    * @param catalog collection of {@link io.airbyte.protocol.models.ConfiguredAirbyteStream}
@@ -48,11 +49,11 @@ public SerializedBufferingStrategy(final CheckedBiFunction<AirbyteStreamNameName
 
   /**
    * Handles both adding records and when buffer is full to also flush
-   * TODO: (ryankfu) when buffer is filled up to write to bucket storage or airbyte_raw table
    *
    * @param stream - stream associated with record
    * @param message - {@link AirbyteMessage} to buffer
-   * @return true if this {@link io.airbyte.protocol.models.AirbyteRecordMessage} causes buffer to flush all messages, otherwise false
+   * @return true if this {@link io.airbyte.protocol.models.AirbyteRecordMessage} causes buffer to
+   *         flush all messages, otherwise false
    * @throws Exception
    */
   @Override