|
43 | 43 | import io.trino.plugin.deltalake.transactionlog.writer.TransactionLogSynchronizerManager; |
44 | 44 | import io.trino.plugin.deltalake.transactionlog.writer.TransactionLogWriterFactory; |
45 | 45 | import io.trino.plugin.hive.FileFormatDataSourceStats; |
46 | | -import io.trino.plugin.hive.HiveLocationService; |
47 | | -import io.trino.plugin.hive.HiveTransactionManager; |
48 | | -import io.trino.plugin.hive.LocationService; |
49 | 46 | import io.trino.plugin.hive.PropertiesSystemTableProvider; |
50 | 47 | import io.trino.plugin.hive.SystemTableProvider; |
51 | 48 | import io.trino.plugin.hive.TransactionalMetadata; |
@@ -107,13 +104,11 @@ public void setup(Binder binder) |
107 | 104 | binder.bind(ConnectorPageSinkProvider.class).to(DeltaLakePageSinkProvider.class).in(Scopes.SINGLETON); |
108 | 105 | binder.bind(ConnectorNodePartitioningProvider.class).to(DeltaLakeNodePartitioningProvider.class).in(Scopes.SINGLETON); |
109 | 106 |
|
110 | | - binder.bind(LocationService.class).to(HiveLocationService.class).in(Scopes.SINGLETON); |
111 | 107 | binder.bind(DeltaLakeMetadataFactory.class).in(Scopes.SINGLETON); |
112 | 108 | binder.bind(CachingExtendedStatisticsAccess.class).in(Scopes.SINGLETON); |
113 | 109 | binder.bind(ExtendedStatisticsAccess.class).to(CachingExtendedStatisticsAccess.class).in(Scopes.SINGLETON); |
114 | 110 | binder.bind(ExtendedStatisticsAccess.class).annotatedWith(ForCachingExtendedStatisticsAccess.class).to(MetaDirStatisticsAccess.class).in(Scopes.SINGLETON); |
115 | 111 | jsonCodecBinder(binder).bindJsonCodec(ExtendedStatistics.class); |
116 | | - binder.bind(HiveTransactionManager.class).in(Scopes.SINGLETON); |
117 | 112 | binder.bind(CheckpointSchemaManager.class).in(Scopes.SINGLETON); |
118 | 113 | jsonCodecBinder(binder).bindJsonCodec(LastCheckpoint.class); |
119 | 114 | binder.bind(CheckpointWriterManager.class).in(Scopes.SINGLETON); |
|
0 commit comments