integrations/flink_connector/src/main/java/com/amazonaws/services/timestream/TimestreamSink.java
integrations/flink_connector_with_upserts/src/main/java/com/amazonaws/services/timestream/TimestreamSink.java

integrations/flink_connector/src/main/java/com/amazonaws/services/timestream/TimestreamPoint.java
integrations/flink_connector_with_upserts/src/main/java/com/amazonaws/services/timestream/TimestreamPoint.java

integrations/flink_connector/src/main/java/com/amazonaws/services/timestream/TimestreamInitializer.java
integrations/flink_connector_with_upserts/src/main/java/com/amazonaws/services/timestream/TimestreamInitializer.java

integrations/flink_connector/src/main/java/com/amazonaws/services/kinesisanalytics/operators/JsonToTimestreamPayloadFn.java
integrations/flink_connector_with_upserts/src/main/java/com/amazonaws/services/timestream/TimestreamPointSchema.java

integrations/flink_connector/src/main/java/com/amazonaws/services/kinesisanalytics/utils/ParameterToolUtils.java
integrations/flink_connector_with_upserts/src/main/java/com/amazonaws/services/kinesisanalytics/utils/ParameterToolUtils.java

integrations/flink_connector/src/main/java/com/amazonaws/services/kinesisanalytics/StreamingJob.java
integrations/flink_connector_with_upserts/src/main/java/com/amazonaws/services/kinesisanalytics/StreamingJob.java

integrations/flink_connector/src/main/java/com/amazonaws/services/timestream/TimestreamInitializer.java
integrations/flink_connector_with_upserts/src/main/java/com/amazonaws/services/timestream/TimestreamSink.java

integrations/flink_connector/src/main/java/com/amazonaws/services/timestream/TimestreamSink.java
integrations/flink_connector_with_upserts/src/main/java/com/amazonaws/services/timestream/TimestreamInitializer.java