| package geode.kafka.sink; |
| |
| import org.junit.Test; |
| |
| public class BatchRecordsTest { |
| @Test |
| public void updatingARecordShouldRemoveFromTheRemoveListIfNullValuesIsRemoveBooleanIsSet() { |
| |
| } |
| |
| @Test |
| public void updatingARecordShouldAddToTheUpdateMap() { |
| |
| } |
| |
| @Test |
| public void updatingARecordShouldNotRemoveFromTheRemoveListIfNullValuesIsNotSet() { |
| |
| } |
| |
| |
| @Test |
| public void removingARecordShouldRemoveFromTheUpdateMap() { |
| |
| } |
| |
| @Test |
| public void removingARecordAddToTheRemoveCollection() { |
| |
| } |
| |
| @Test |
| public void executeOperationsShouldInvokePutAllAndRemoveAll() { |
| |
| } |
| |
| |
| |
| } |