### Question:
KinesisTableDescriptionSupplier implements Supplier<Map<SchemaTableName, KinesisStreamDescription>> { @Override public Map<SchemaTableName, KinesisStreamDescription> get() { if (s3TableConfigClient.isUsingS3()) { return s3TableConfigClient.getTablesFromS3(); } return getTablesFromPath(); } @Inject  KinesisTableDescriptionSupplier(
            KinesisConfig kinesisConfig,
            JsonCodec<KinesisStreamDescription> streamDescriptionCodec,
            S3TableConfigClient s3TableConfigClient); @Override Map<SchemaTableName, KinesisStreamDescription> get(); Map<SchemaTableName, KinesisStreamDescription> getTablesFromPath(); @PreDestroy void shutdown();  }### Answer:
@Test public void testRelatedObjects() { KinesisMetadata metadata = (KinesisMetadata) connector.getMetadata(new ConnectorTransactionHandle() {}); assertNotNull(metadata); SchemaTableName tblName = new SchemaTableName("prod", "test_table"); List<String> schemas = metadata.listSchemaNames(null); assertEquals(schemas.size(), 1); assertEquals(schemas.get(0), "prod"); KinesisTableHandle tblHandle = metadata.getTableHandle(null, tblName); assertNotNull(tblHandle); assertEquals(tblHandle.getSchemaName(), "prod"); assertEquals(tblHandle.getTableName(), "test_table"); assertEquals(tblHandle.getStreamName(), "test_kinesis_stream"); assertEquals(tblHandle.getMessageDataFormat(), "json"); ConnectorTableMetadata tblMeta = metadata.getTableMetadata(null, tblHandle); assertNotNull(tblMeta); assertEquals(tblMeta.getTable().getSchemaName(), "prod"); assertEquals(tblMeta.getTable().getTableName(), "test_table"); List<ColumnMetadata> columnList = tblMeta.getColumns(); assertNotNull(columnList); boolean foundServiceType = false; boolean foundPartitionKey = false; for (ColumnMetadata column : columnList) { if (column.getName().equals("service_type")) { foundServiceType = true; assertEquals(column.getType().getDisplayName(), "varchar(20)"); } if (column.getName().equals("_partition_key")) { foundPartitionKey = true; assertEquals(column.getType().getDisplayName(), "varchar"); } } assertTrue(foundServiceType); assertTrue(foundPartitionKey); }