Package cz.o2.proxima.direct.io.s3
Class S3LogReader
- java.lang.Object
-
- cz.o2.proxima.direct.io.blob.BlobLogReader<S3BlobPath.S3Blob,S3BlobPath>
-
- cz.o2.proxima.direct.io.s3.S3LogReader
-
- All Implemented Interfaces:
BatchLogReader
public class S3LogReader extends BlobLogReader<S3BlobPath.S3Blob,S3BlobPath>
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 S3LogReader(cz.o2.proxima.direct.io.s3.S3Accessor 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 S3BlobPath
createPath(S3BlobPath.S3Blob blob)
protected void
runHandlingErrors(S3BlobPath.S3Blob 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
-
S3LogReader
public S3LogReader(cz.o2.proxima.direct.io.s3.S3Accessor accessor, Context context)
-
-
Method Detail
-
runHandlingErrors
protected void runHandlingErrors(S3BlobPath.S3Blob blob, BlobLogReader.ThrowingRunnable runnable)
- Specified by:
runHandlingErrors
in classBlobLogReader<S3BlobPath.S3Blob,S3BlobPath>
-
createPath
protected S3BlobPath createPath(S3BlobPath.S3Blob blob)
- Specified by:
createPath
in classBlobLogReader<S3BlobPath.S3Blob,S3BlobPath>
-
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
-
-