33
33
import java .util .stream .Collectors ;
34
34
35
35
public class JavaFetcher {
36
- Fetcher Fetcher ;
36
+ Fetcher fetcher ;
37
37
38
38
public JavaFetcher (KVStore kvStore , String metaDataSet , Long timeoutMillis , Consumer <LoggableResponse > logFunc , ExternalSourceRegistry registry , String callerName , Boolean disableErrorThrows ) {
39
- this .Fetcher = new Fetcher (kvStore , metaDataSet , timeoutMillis , logFunc , false , registry , callerName , null , disableErrorThrows , null );
39
+ this .fetcher = new Fetcher (kvStore , metaDataSet , timeoutMillis , logFunc , false , registry , callerName , null , disableErrorThrows , null );
40
40
}
41
41
42
42
public JavaFetcher (KVStore kvStore , String metaDataSet , Long timeoutMillis , Consumer <LoggableResponse > logFunc , ExternalSourceRegistry registry ) {
43
- this .Fetcher = new Fetcher (kvStore , metaDataSet , timeoutMillis , logFunc , false , registry , null , null , false , null );
43
+ this .fetcher = new Fetcher (kvStore , metaDataSet , timeoutMillis , logFunc , false , registry , null , null , false , null );
44
44
}
45
45
46
46
public JavaFetcher (KVStore kvStore , String metaDataSet , Long timeoutMillis , Consumer <LoggableResponse > logFunc , ExternalSourceRegistry registry , String callerName , FlagStore flagStore , Boolean disableErrorThrows ) {
47
- this .Fetcher = new Fetcher (kvStore , metaDataSet , timeoutMillis , logFunc , false , registry , callerName , flagStore , disableErrorThrows , null );
47
+ this .fetcher = new Fetcher (kvStore , metaDataSet , timeoutMillis , logFunc , false , registry , callerName , flagStore , disableErrorThrows , null );
48
48
}
49
49
50
50
/* user builder pattern to create JavaFetcher
@@ -56,7 +56,7 @@ public JavaFetcher(KVStore kvStore, String metaDataSet, Long timeoutMillis, Cons
56
56
.build();
57
57
*/
58
58
private JavaFetcher (Builder builder ) {
59
- this .Fetcher = new Fetcher (builder .kvStore ,
59
+ this .fetcher = new Fetcher (builder .kvStore ,
60
60
builder .metaDataSet ,
61
61
builder .timeoutMillis ,
62
62
builder .logFunc ,
@@ -155,7 +155,7 @@ public CompletableFuture<List<JavaResponse>> fetchGroupBys(List<JavaRequest> req
155
155
// Convert java requests to scala requests
156
156
Seq <Fetcher .Request > scalaRequests = convertJavaRequestList (requests , true , startTs );
157
157
// Get responses from the fetcher
158
- Future <FetcherResponseWithTs > scalaResponses = this .Fetcher .withTs (this .Fetcher .fetchGroupBys (scalaRequests ));
158
+ Future <FetcherResponseWithTs > scalaResponses = this .fetcher .withTs (this .fetcher .fetchGroupBys (scalaRequests ));
159
159
// Convert responses to CompletableFuture
160
160
return convertResponsesWithTs (scalaResponses , true , startTs );
161
161
}
@@ -165,7 +165,7 @@ public CompletableFuture<List<JavaResponse>> fetchJoin(List<JavaRequest> request
165
165
// Convert java requests to scala requests
166
166
Seq <Fetcher .Request > scalaRequests = convertJavaRequestList (requests , false , startTs );
167
167
// Get responses from the fetcher
168
- Future <FetcherResponseWithTs > scalaResponses = this .Fetcher .withTs (this .Fetcher .fetchJoin (scalaRequests , Option .empty ()));
168
+ Future <FetcherResponseWithTs > scalaResponses = this .fetcher .withTs (this .fetcher .fetchJoin (scalaRequests , Option .empty ()));
169
169
// Convert responses to CompletableFuture
170
170
return convertResponsesWithTs (scalaResponses , false , startTs );
171
171
}
0 commit comments