100644 blob a3df0f1b663276be18ea50de6f6f6da6eb2680b1	KinesisByteArrayOutputOperatorTest.java
100644 blob a0eb0426cd28c57b1a94e7c0b10939172fe8dcb2	KinesisInputOperatorTest.java
100644 blob c9948ba49ca11ed7325e8d7dc086bb3277b935f3	KinesisOperatorTestBase.java
100644 blob b478b9fd59b81fc74fd65733df069f38d95ecb2b	KinesisOutputOperatorTest.java
100644 blob f1e1e5f167418ace5fc5daaac48cb775d0739c50	KinesisPartitionableInputOperatorTest.java
100644 blob f0a9eb7225570a839f2b4d16420cb5735bb356b0	KinesisStringOutputOperatorTest.java
100644 blob a1547c12a68d75bd1163a55948b4c74bb2fd99e5	KinesisTestConsumer.java
100644 blob fe1a2e220f8f8fcba4183d0b494e2cd31ecc0cdd	KinesisTestProducer.java
100644 blob 7948d10eced19088a8ffb8cbdfef3bf36056a471	ShardManagerTest.java