org.springframework.cloud.gcp.storage.integration.filters

Class GcsPersistentAcceptOnceFileListFilter

java.lang.Object

org.springframework.integration.file.filters.AbstractFileListFilter<F>

org.springframework.integration.file.filters.AbstractPersistentAcceptOnceFileListFilter<BlobInfo>

org.springframework.cloud.gcp.storage.integration.filters.GcsPersistentAcceptOnceFileListFilter

All Implemented Interfaces:

Closeable, AutoCloseable, org.springframework.integration.file.filters.FileListFilter<BlobInfo>, org.springframework.integration.file.filters.ResettableFileListFilter<BlobInfo>, org.springframework.integration.file.filters.ReversibleFileListFilter<BlobInfo>

public class GcsPersistentAcceptOnceFileListFilter
extends org.springframework.integration.file.filters.AbstractPersistentAcceptOnceFileListFilter<BlobInfo>

A filter for Google Cloud Storage.

Author:

João André Martins, Chengyuan Zhao, Lukas Gemela

Field Summary

Fields inherited from class org.springframework.integration.file.filters.AbstractPersistentAcceptOnceFileListFilter

flushableStore, flushOnUpdate, prefix, store

Constructor Summary

Constructors

Constructor and Description
GcsPersistentAcceptOnceFileListFilter(org.springframework.integration.metadata.ConcurrentMetadataStore store, String prefix)

Method Summary

Modifier and Type	Method and Description
protected String	fileName(BlobInfo blobInfo)
protected long	modified(BlobInfo blobInfo)

Methods inherited from class org.springframework.integration.file.filters.AbstractPersistentAcceptOnceFileListFilter

accept, buildKey, close, fileStillExists, flushIfNeeded, isEqual, remove, rollback, setFlushOnUpdate

Methods inherited from class org.springframework.integration.file.filters.AbstractFileListFilter

filterFiles, supportsSingleFileFiltering

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.springframework.integration.file.filters.FileListFilter

filterFiles, supportsSingleFileFiltering

Constructor Detail

GcsPersistentAcceptOnceFileListFilter

public GcsPersistentAcceptOnceFileListFilter(org.springframework.integration.metadata.ConcurrentMetadataStore store,
                                             String prefix)

Method Detail

modified

protected long modified(BlobInfo blobInfo)

Specified by:

modified in class org.springframework.integration.file.filters.AbstractPersistentAcceptOnceFileListFilter<BlobInfo>

fileName

protected String fileName(BlobInfo blobInfo)

Specified by:

fileName in class org.springframework.integration.file.filters.AbstractPersistentAcceptOnceFileListFilter<BlobInfo>