org.codice.ddf.commands.catalog

Class DuplicateCommands

java.lang.Object

org.codice.ddf.commands.catalog.CommandSupport

org.codice.ddf.commands.catalog.SubjectCommands

org.codice.ddf.commands.catalog.CatalogCommands

org.codice.ddf.commands.catalog.CqlCommands

org.codice.ddf.commands.catalog.DuplicateCommands

All Implemented Interfaces:

org.apache.karaf.shell.api.action.Action

Direct Known Subclasses:

MigrateCommand, ReplicateCommand

public abstract class DuplicateCommands
extends CqlCommands

Field Summary

Fields

Modifier and Type	Field and Description
protected AtomicInteger	failedCount
protected Set<Metacard>	failedMetacards
protected AtomicInteger	ingestedCount
protected static int	MAX_BATCH_SIZE
protected long	start

Fields inherited from class org.codice.ddf.commands.catalog.CqlCommands

DATE_FORMAT, DEFAULT_TEMPORAL_PROPERTY

Fields inherited from class org.codice.ddf.commands.catalog.CatalogCommands

bundleContext, catalogFramework, catalogProvider, DATETIME_FORMATTER, DEFAULT_NUMBER_OF_ITEMS, DEFAULT_TRANSFORMER_ID, ESCAPE, filterBuilder, isProvider, NAMESPACE, SERIALIZED_OBJECT_ID, SINGLE_WILDCARD, WILDCARD

Fields inherited from class org.codice.ddf.commands.catalog.SubjectCommands

session, user

Fields inherited from class org.codice.ddf.commands.catalog.CommandSupport

console, ERROR_COLOR, MS_PER_SECOND

Constructor Summary

Constructors

Constructor and Description
DuplicateCommands()

Method Summary

Modifier and Type	Method and Description
protected void	duplicateInBatches(CatalogFacade queryFacade, CatalogFacade ingestFacade, org.opengis.filter.Filter filter, String sourceId) In batches, loops through a query of the queryFacade and an ingest to the ingestFacade of the metacards from the response until there are no more metacards from the queryFacade or the maxMetacards has been reached.
protected List<Metacard>	ingestMetacards(CatalogFacade provider, List<Metacard> metacards)
protected List<Metacard>	subtract(List<Metacard> queried, List<Metacard> ingested)
protected void	writeFailedMetacards(Set<Metacard> failedMetacardsToWrite)

Methods inherited from class org.codice.ddf.commands.catalog.CqlCommands

getFilter, getFilter, getFilterStartTime, getTemporalProperty, hasFilter

Methods inherited from class org.codice.ddf.commands.catalog.CatalogCommands

getCacheProxy, getCatalog, getFormattedDuration, getFormattedDuration, getServiceByFilter

Methods inherited from class org.codice.ddf.commands.catalog.SubjectCommands

execute, executeWithSubject

Methods inherited from class org.codice.ddf.commands.catalog.CommandSupport

calculateRecordsPerSecond, printColor, printErrorMessage, printHeaderMessage, printProgressAndFlush, printSuccessMessage

Methods inherited from class java.lang.Object

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

Field Detail

MAX_BATCH_SIZE

protected static final int MAX_BATCH_SIZE

See Also:

Constant Field Values

ingestedCount

protected AtomicInteger ingestedCount

failedCount

protected AtomicInteger failedCount

failedMetacards

protected Set<Metacard> failedMetacards

start

protected long start

Constructor Detail

DuplicateCommands

public DuplicateCommands()

Method Detail

duplicateInBatches

protected void duplicateInBatches(CatalogFacade queryFacade,
                                  CatalogFacade ingestFacade,
                                  org.opengis.filter.Filter filter,
                                  String sourceId)

In batches, loops through a query of the queryFacade and an ingest to the ingestFacade of the metacards from the response until there are no more metacards from the queryFacade or the maxMetacards has been reached.

Parameters:

queryFacade - - the CatalogFacade to duplicate from

ingestFacade - - the CatalogFacade to duplicate to

filter - - the filter to query with

ingestMetacards

protected List<Metacard> ingestMetacards(CatalogFacade provider,
                                         List<Metacard> metacards)

subtract

protected List<Metacard> subtract(List<Metacard> queried,
                                  List<Metacard> ingested)

writeFailedMetacards

protected void writeFailedMetacards(Set<Metacard> failedMetacardsToWrite)
                             throws IOException

Throws:

IOException