@@ -95,9 +95,7 @@ public RFileScannerEnvironmentImpl(Opts opts) {
95
95
96
96
@ Override
97
97
public String getTableName (TableId tableId ) throws TableNotFoundException {
98
- Preconditions .checkArgument (tableId == TABLE_ID , "Expected " + TABLE_ID + " obtained"
99
- + " from IteratorEnvironment.getTableId(), but got: " + tableId );
100
- return TABLE_NAME ;
98
+ return null ;
101
99
}
102
100
103
101
@ Override
@@ -107,17 +105,13 @@ public Configuration getConfiguration() {
107
105
108
106
@ Override
109
107
public Configuration getConfiguration (TableId tableId ) {
110
- Preconditions .checkArgument (tableId == TABLE_ID , "Expected " + TABLE_ID + " obtained"
111
- + " from IteratorEnvironment.getTableId(), but got: " + tableId );
112
108
return tableConf ;
113
109
}
114
110
115
111
}
116
112
117
113
private static final byte [] EMPTY_BYTES = new byte [0 ];
118
114
private static final Range EMPTY_RANGE = new Range ();
119
- private static final String TABLE_NAME = "rfileScanner" ;
120
- private static final TableId TABLE_ID = TableId .of (TABLE_NAME );
121
115
122
116
private Range range ;
123
117
private BlockCacheManager blockCacheManager = null ;
@@ -309,7 +303,7 @@ public Iterator<Entry<Key,Value>> iterator() {
309
303
310
304
ClientIteratorEnvironment .Builder iterEnvBuilder = new ClientIteratorEnvironment .Builder ()
311
305
.withEnvironment (new RFileScannerEnvironmentImpl (opts )).withAuthorizations (opts .auths )
312
- .withScope (IteratorScope .scan ).withTableId (TABLE_ID );
306
+ .withScope (IteratorScope .scan ).withTableId (null );
313
307
if (getSamplerConfiguration () != null ) {
314
308
iterEnvBuilder .withSamplerConfiguration (getSamplerConfiguration ());
315
309
iterEnvBuilder .withSamplingEnabled ();
0 commit comments