def _assert_common_cols(self, cols):
    self.assertEqual('KafkaPartition', cols[0].name)
    self.assertEqual(dtypes.int32, cols[0].data_type)
    self.assertEqual('KafkaOffset', cols[1].name)
    self.assertEqual(dtypes.long, cols[1].data_type)
    self.assertEqual('KafkaTimestamp', cols[2].name)
    self.assertEqual(dtypes.DateTime, cols[2].data_type)
def _assert_common_cols(self, cols):
    self.assertEqual('KafkaPartition', cols[0].name)
    self.assertEqual(dtypes.int32, cols[0].data_type)
    self.assertEqual('KafkaOffset', cols[1].name)
    self.assertEqual(dtypes.long, cols[1].data_type)
    self.assertEqual('KafkaTimestamp', cols[2].name)
    self.assertEqual(dtypes.DateTime, cols[2].data_type)