Package org.codice.alliance.video.stream.mpegts.plugins

Class FindChildrenStreamEndPlugin

java.lang.Object

org.codice.alliance.video.stream.mpegts.plugins.FindChildrenStreamEndPlugin

All Implemented Interfaces:

StreamEndPlugin

public class FindChildrenStreamEndPlugin
extends Object
implements StreamEndPlugin

Find the children of the parent metacard and process the children in batches. The children will be processed in the order in which they were originally created. If an exception occurs during when a batch is being retrieved from the CatalogFramework or from a batch handler, then the FindChildrenStreamEndPlugin.Handler.end(Context, Metacard) will not be called.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	FindChildrenStreamEndPlugin.Factory	Factory for building FindChildrenStreamEndPlugin.Handler
static interface	FindChildrenStreamEndPlugin.Handler	Handle the children.

Field Summary

Fields

Modifier and Type	Field	Description
static final int	BATCH_SIZE
static final int	MAX_SUBSEQUENT_ERROR_COUNT

Constructor Summary

Constructors

Constructor	Description
FindChildrenStreamEndPlugin(ddf.catalog.filter.FilterBuilder filterBuilder, FindChildrenStreamEndPlugin.Factory factory)

Method Summary

Modifier and Type	Method	Description
FindChildrenStreamEndPlugin.Factory	getFactory()
void	streamEnded(Context context)

Methods inherited from class java.lang.Object

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

Field Details

MAX_SUBSEQUENT_ERROR_COUNT

public static final int MAX_SUBSEQUENT_ERROR_COUNT

See Also:

• Constant Field Values

BATCH_SIZE

public static final int BATCH_SIZE

See Also:

• Constant Field Values

Constructor Details

FindChildrenStreamEndPlugin

public FindChildrenStreamEndPlugin(ddf.catalog.filter.FilterBuilder filterBuilder,
 FindChildrenStreamEndPlugin.Factory factory)

Method Details

getFactory

public FindChildrenStreamEndPlugin.Factory getFactory()

streamEnded

public void streamEnded(Context context)

Specified by:

streamEnded in interface StreamEndPlugin