public CassandraSink < IN > slotSharingGroup ( String slotSharingGroup ) { if ( useDataStreamSink ) { getSinkTransformation ( ) . setSlotSharingGroup ( slotSharingGroup ) ; } else { getStreamTransformation ( ) . setSlotSharingGroup ( slotSharingGroup ) ; } return this ; }
Sets the slot sharing group of this operation . Parallel instances of operations that are in the same slot sharing group will be co - located in the same TaskManager slot if possible .