amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/DynamoDBStreamsDataFetcher.java [79:84]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
				sourceContext,
				sourceContext.getCheckpointLock(),
				runtimeContext,
				configProps,
				deserializationSchema,
				shardAssigner,
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/KinesisDataFetcher.java [382:387]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
				sourceContext,
				sourceContext.getCheckpointLock(),
				runtimeContext,
				configProps,
				deserializationSchema,
				shardAssigner,
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -