Class GCloudLogReader
- java.lang.Object
-
- cz.o2.proxima.direct.io.blob.BlobLogReader<GCloudBlobPath.GCloudBlob,GCloudBlobPath>
-
- cz.o2.proxima.direct.io.gcloud.storage.GCloudLogReader
-
- All Implemented Interfaces:
BatchLogReader
public class GCloudLogReader extends BlobLogReader<GCloudBlobPath.GCloudBlob,GCloudBlobPath>
BatchLogReader
for gcloud storage.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class cz.o2.proxima.direct.io.blob.BlobLogReader
BlobLogReader.ThrowingRunnable
-
Nested classes/interfaces inherited from interface cz.o2.proxima.direct.core.batch.BatchLogReader
BatchLogReader.Factory<T extends BatchLogReader>
-
-
Constructor Summary
Constructors Constructor Description GCloudLogReader(cz.o2.proxima.direct.io.gcloud.storage.GCloudStorageAccessor accessor, Context context)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description BatchLogReader.Factory<?>
asFactory()
Convert instance of this reader toBatchLogReader.Factory
suitable for serialization.protected BlobPath<GCloudBlobPath.GCloudBlob>
createPath(GCloudBlobPath.GCloudBlob blob)
protected void
runHandlingErrors(GCloudBlobPath.GCloudBlob blob, BlobLogReader.ThrowingRunnable runnable)
-
Methods inherited from class cz.o2.proxima.direct.io.blob.BlobLogReader
getPartitions, observe
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface cz.o2.proxima.direct.core.batch.BatchLogReader
getPartitions, getPartitions, observeOffsets
-
-
-
-
Constructor Detail
-
GCloudLogReader
public GCloudLogReader(cz.o2.proxima.direct.io.gcloud.storage.GCloudStorageAccessor accessor, Context context)
-
-
Method Detail
-
runHandlingErrors
protected void runHandlingErrors(GCloudBlobPath.GCloudBlob blob, BlobLogReader.ThrowingRunnable runnable)
- Specified by:
runHandlingErrors
in classBlobLogReader<GCloudBlobPath.GCloudBlob,GCloudBlobPath>
-
createPath
protected BlobPath<GCloudBlobPath.GCloudBlob> createPath(GCloudBlobPath.GCloudBlob blob)
- Specified by:
createPath
in classBlobLogReader<GCloudBlobPath.GCloudBlob,GCloudBlobPath>
-
asFactory
public BatchLogReader.Factory<?> asFactory()
Description copied from interface:BatchLogReader
Convert instance of this reader toBatchLogReader.Factory
suitable for serialization.- Returns:
- the
BatchLogReader.Factory
representing this reader
-
-