@Override
	protected void onInit() throws Exception {
		super.onInit();
		Assert.notNull(storePartitionWriter, "Data Writer must be set");
	}
Instantiates a new hdfs partition data store message handler.

@param storePartitionWriter the store partition writer
spring-xd-hadoop/src/main/java/org/springframework/xd/integration/hadoop/outbound/HdfsPartitionDataStoreMessageHandler.java