def test_sink_display_data(self):
    file_name = 'some_avro_sink'
    sink = _create_avro_sink(file_name, self.SCHEMA, 'null', '.end', 0, None, 'application/x-avro', use_fastavro=self.use_fastavro)
    dd = DisplayData.create_from(sink)
    expected_items = [DisplayDataItemMatcher('schema', str(self.SCHEMA)), DisplayDataItemMatcher('file_pattern', 'some_avro_sink-%(shard_num)05d-of-%(num_shards)05d.end'), DisplayDataItemMatcher('codec', 'null'), DisplayDataItemMatcher('compression', 'uncompressed')]
    hc.assert_that(dd.items, hc.contains_inanyorder(*expected_items))
def test_sink_display_data(self):
    file_name = 'some_avro_sink'
    sink = _create_avro_sink(file_name, self.SCHEMA, 'null', '.end', 0, None, 'application/x-avro', use_fastavro=self.use_fastavro)
    dd = DisplayData.create_from(sink)
    expected_items = [DisplayDataItemMatcher('schema', str(self.SCHEMA)), DisplayDataItemMatcher('file_pattern', 'some_avro_sink-%(shard_num)05d-of-%(num_shards)05d.end'), DisplayDataItemMatcher('codec', 'null'), DisplayDataItemMatcher('compression', 'uncompressed')]
    hc.assert_that(dd.items, hc.contains_inanyorder(*expected_items))