class FlinkKinesisProducer extends RichSinkFunction<OUT> implements CheckpointedFunction {

	public void setCustomPartitioner(KinesisPartitioner<OUT> partitioner) {
		checkNotNull(partitioner, "partitioner cannot be null");
		checkArgument(
			InstantiationUtil.isSerializable(partitioner),
			"The provided custom partitioner is not serializable: " + partitioner.getClass().getName() + ". " +
				"Please check that it does not contain references to non-serializable instances.");

		this.customPartitioner = partitioner;
	}

	public  FlinkKinesisProducer(final SerializationSchema<OUT> schema, Properties configProps);
	public  FlinkKinesisProducer(KinesisSerializationSchema<OUT> schema, Properties configProps);

}