Path Lines of Code integrations/flink_connector_with_upserts/src/main/java/com/amazonaws/services/kinesisanalytics/StreamingJob.java 88 integrations/flink_connector_with_upserts/src/main/java/com/amazonaws/services/kinesisanalytics/operators/TimestreamPointToAverage.java 43 integrations/flink_connector_with_upserts/src/main/java/com/amazonaws/services/kinesisanalytics/utils/ParameterToolUtils.java 23 integrations/flink_connector_with_upserts/src/main/java/com/amazonaws/services/timestream/TimestreamInitializer.java 48 integrations/flink_connector_with_upserts/src/main/java/com/amazonaws/services/timestream/TimestreamPoint.java 79 integrations/flink_connector_with_upserts/src/main/java/com/amazonaws/services/timestream/TimestreamPointSchema.java 55 integrations/flink_connector_with_upserts/src/main/java/com/amazonaws/services/timestream/TimestreamSink.java 124