Package | Description |
---|---|
io.druid.firehose.google |
Modifier and Type | Method and Description |
---|---|
List<GoogleBlob> |
StaticGoogleBlobStoreFirehoseFactory.getBlobs() |
protected Collection<GoogleBlob> |
StaticGoogleBlobStoreFirehoseFactory.initObjects() |
Modifier and Type | Method and Description |
---|---|
protected InputStream |
StaticGoogleBlobStoreFirehoseFactory.openObjectStream(GoogleBlob object) |
protected InputStream |
StaticGoogleBlobStoreFirehoseFactory.wrapObjectStream(GoogleBlob object,
InputStream stream) |
Constructor and Description |
---|
StaticGoogleBlobStoreFirehoseFactory(GoogleStorage storage,
List<GoogleBlob> blobs,
Long maxCacheCapacityBytes,
Long maxFetchCapacityBytes,
Long prefetchTriggerBytes,
Long fetchTimeout,
Integer maxFetchRetry) |
Copyright © 2011–2018. All rights reserved.